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

1 entries across 1 versions & 1 rubygems

Version	Path
bmabey-rosetta_queue-0.3.3	lib/rosetta_queue/producer.rb