Contents

module RosettaQueue
  
  class Producer < Base
    include MessageHandler

    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.publish: #{$!}\n" + e.backtrace.join("\n\t"))
    end

  end
end

Version data entries

5 entries across 5 versions & 2 rubygems

Version	Path
bmabey-rosetta_queue-0.2.0	lib/rosetta_queue/producer.rb
cwyckoff-rosetta_queue-0.1.4	lib/rosetta_queue/producer.rb
cwyckoff-rosetta_queue-0.2.2	lib/rosetta_queue/producer.rb
cwyckoff-rosetta_queue-0.3.0	lib/rosetta_queue/producer.rb
cwyckoff-rosetta_queue-0.3.3	lib/rosetta_queue/producer.rb