Contents

module RosettaQueue

  class Producer
    include MessageHandler

    def self.publish(destination, message, options = {})
      ExceptionHandler::handle(:publishing,
        lambda {
          {:message => Filters.safe_process_sending(message),
           :action => :publishing,
           :destination => destination,
           :options => options}
        }) do
        RosettaQueue::Adapter.open do |a|
          a.send_message(
            Destinations.lookup(destination),
            Filters.process_sending(message),
            options)
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
rosetta_queue-0.5.2	lib/rosetta_queue/producer.rb
rosetta_queue-0.5.0	lib/rosetta_queue/producer.rb