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

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
cwyckoff-rosetta_queue-0.2.1	lib/rosetta_queue/producer.rb