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.



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

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

Instance Method Details

#delete_queue(name) ⇒ Object 



27
28
29
 
# File 'lib/flu-rails/queue_repository.rb', line 27

def delete_queue(name)
  @management_client.delete_queue("/", name)
end

#find_all ⇒ Object 



11
12
13
 
# File 'lib/flu-rails/queue_repository.rb', line 11

def find_all
  @management_client.list_queues
end

#find_bindings_for_queue(name) ⇒ Object 



19
20
21
 
# File 'lib/flu-rails/queue_repository.rb', line 19

def find_bindings_for_queue(name)
  @management_client.list_queue_bindings("/", name)
end

#find_queue(name) ⇒ Object 



15
16
17
 
# File 'lib/flu-rails/queue_repository.rb', line 15

def find_queue(name)
  @management_client.queue_info("/", name)
end

#purge_queue(name) ⇒ Object 



23
24
25
 
# File 'lib/flu-rails/queue_repository.rb', line 23

def purge_queue(name)
  @management_client.purge_queue("/", name)
end