Contents

module RosettaQueue

  class Producer < Base
    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.instance.send_message(
          Destinations.lookup(destination),
          Filters.process_sending(message),
          options)
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rosetta_queue-0.4.0	lib/rosetta_queue/producer.rb