Contents

module HornetQ::Client
  # Create a Server following the ServerPattern for receiving requests and 
  # replying to arbitrary queues
  # Create an instance of this class per thread
  class ServerPattern
    def initialize(session, request_queue, timeout)
      @session = session
      @consumer = session.create_consumer(request_queue)
      @producer = session.create_producer
      @timeout = timeout
    end
  
    def run(&block)
      while request_message = @consumer.receive(@timeout)
        # Block should return a message reply object, pass in request
        # TODO: ensure..
        reply_message = block.call(request_message)
      
        # Send a reply?
        reply(request_message, reply_message) if request_message.request?
        request_message.acknowledge
      end
    end

    # Send a reply to the received request message
    #   request: is the message received
    #   reply:   is the message to send to the client
    #
    # Note: A reply is only sent if it is a request message. This means that
    #       the message must have a property named Java::OrgHornetqCoreClientImpl::ClientMessageImpl::REPLYTO_HEADER_NAME
    #       containing the name of the address to which the response should be sent
    def reply(request_message, reply_message)
      if request_message.request?
        # Reply should have same durability as request
        reply_message.durable = request_message.durable?
        # Send request message id back in reply message for correlation purposes
        reply_message.user_id = request_message.user_id
        # Send to Reply to address supplied by the caller
        @producer.send(request_message.reply_to_address, reply_message)
        #puts "Sent reply to #{reply_to.to_s}: #{reply_message.inspect}"
      end
      request_message.acknowledge
    end
  
    # Close out resources
    def close
      @consumer.close if @consumer
      @producer.close if @producer
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
jruby-hornetq-0.3.3	lib/hornetq/client/server_pattern.rb
jruby-hornetq-0.3.2	lib/hornetq/client/server_pattern.rb