Contents

# @api private
module Torquebox
  module Messaging
    # A message processor that echos any messages sent to it back to
    # another queue specified by the response_queue configuration option
    class EchoProcessor < TorqueBox::Messaging::MessageProcessor

      def initialize(options={})
        @response_queue = TorqueBox::Messaging::Queue.new(options['response_queue'])
      end

      def on_message(body)
        @response_queue.publish(body)
      end

    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
torquebox-messaging-2.2.0-java	lib/torquebox/messaging/echo_processor.rb