Class: RosettaQueue::Producer

Inherits:
Base
  • Object
show all
Includes:
MessageHandler
Defined in:
lib/rosetta_queue/producer.rb

Class Method Summary collapse

Methods included from MessageHandler

#destination, included, #options_hash

Methods inherited from Base

#disconnect

Class Method Details

.publish(destination, message, options = {}) ⇒ Object 



6
7
8
9
10
11
 
# File 'lib/rosetta_queue/producer.rb', line 6

def self.publish(destination, message, options = {})
  RosettaQueue::Adapter.instance.send_message(Destinations.lookup(destination), Filters.process_sending(message), options)

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