Class: Flu::QueueRepository

Inherits:
Object
  • Object
show all
Defined in:
lib/flu-rails/queue_repository.rb

Instance Method Summary collapse

Constructor Details

#initialize(configuration) ⇒ QueueRepository

Returns a new instance of QueueRepository.



7
8
9
10
11
 
# File 'lib/flu-rails/queue_repository.rb', line 7

def initialize(configuration)
  @logger            = configuration.logger
  @configuration     = configuration
  @management_client = create_management_client(configuration)
end

Instance Method Details

#delete_queue(name) ⇒ Object 



29
30
31
 
# File 'lib/flu-rails/queue_repository.rb', line 29

def delete_queue(name)
  @management_client.delete_queue(@configuration.rabbitmq_vhost, name)
end

#find_all ⇒ Object 



13
14
15
 
# File 'lib/flu-rails/queue_repository.rb', line 13

def find_all
  @management_client.list_queues(@configuration.rabbitmq_vhost)
end

#find_bindings_for_queue(name) ⇒ Object 



21
22
23
 
# File 'lib/flu-rails/queue_repository.rb', line 21

def find_bindings_for_queue(name)
  @management_client.list_queue_bindings(@configuration.rabbitmq_vhost, name)
end

#find_queue(name) ⇒ Object 



17
18
19
 
# File 'lib/flu-rails/queue_repository.rb', line 17

def find_queue(name)
  @management_client.queue_info(@configuration.rabbitmq_vhost, name)
end

#purge_queue(name) ⇒ Object 



25
26
27
 
# File 'lib/flu-rails/queue_repository.rb', line 25

def purge_queue(name)
  @management_client.purge_queue(@configuration.rabbitmq_vhost, name)
end