Class: Brown::QueueFactory

Inherits:
Object
  • Object
show all
Defined in:
lib/brown/queue_factory.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ QueueFactory

Returns a new instance of QueueFactory.



4
5
6
 
# File 'lib/brown/queue_factory.rb', line 4

def initialize
  @cache = {}
end

Instance Method Details

#each_queue ⇒ Object

Passes each queue to the supplied block.



23
24
25
26
27
 
# File 'lib/brown/queue_factory.rb', line 23

def each_queue
  @cache.values.each do |queue|
    yield queue if block_given?
  end
end

#queues ⇒ Object

Returns all queues as a hash, with the queue name being the key.



30
31
32
 
# File 'lib/brown/queue_factory.rb', line 30

def queues
  @cache
end

#receiver(queue_name, opts = {}, &blk) ⇒ Object

Convenience method that returns a Receiver object.



16
17
18
19
20
 
# File 'lib/brown/queue_factory.rb', line 16

def receiver(queue_name, opts={}, &blk)
  k = "receiver:#{queue_name}"
  @cache[k] ||= Brown::Receiver.new(queue_name, opts)
  blk.call(@cache[k])
end

#sender(queue_name, opts = {}, &blk) ⇒ Object

Convenience method that returns a Sender object.



9
10
11
12
13
 
# File 'lib/brown/queue_factory.rb', line 9

def sender(queue_name, opts={}, &blk)
  k = "sender:#{queue_name}"
  @cache[k] ||= Brown::Sender.new(queue_name, opts)
  blk.call(@cache[k])
end