Class: RosettaQueue::Consumer

Inherits:
Base
  • Object
show all
Defined in:
lib/rosetta_queue/consumer.rb

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from Base

#disconnect

Constructor Details

#initialize(message_handler) ⇒ Consumer

Returns a new instance of Consumer.



11
12
13
 
# File 'lib/rosetta_queue/consumer.rb', line 11

def initialize(message_handler)
  @message_handler = message_handler
end

Class Method Details

.receive(destination, options = {}) ⇒ Object 



4
5
6
7
8
9
 
# File 'lib/rosetta_queue/consumer.rb', line 4

def self.receive(destination, options = {})
  RosettaQueue::Adapter.instance.receive_once(Destinations.lookup(destination), options)
  
  rescue Exception=>e
    RosettaQueue.logger.error("Caught exception in Consumer#receive: #{$!}\n" + e.backtrace.join("\n\t"))
end

Instance Method Details

#receive ⇒ Object 



15
16
17
18
19
20
 
# File 'lib/rosetta_queue/consumer.rb', line 15

def receive
  connection.receive_with(@message_handler)
  
  rescue Exception=>e
    RosettaQueue.logger.error("Caught exception in Consumer#receive: #{$!}\n" + e.backtrace.join("\n\t"))
end