Contents

# Add methods to Session Interface
module Java::org.hornetq.api.core.client::ClientSession
  
  # To be consistent create Requestor from Session
  def create_requestor(request_address)
    #Java::org.hornetq.api.core.client::ClientRequestor.new(self, request_address);
    HornetQ::Client::Requestor.new(self, request_address)
  end
  
  # Create a server handler for receiving requests and responding with
  # replies to the supplied address
  def create_server(input_queue, timeout=0)
    HornetQ::Client::Server.new(self, input_queue, timeout)
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
jruby-hornetq-0.2.3.alpha	lib/hornetq/client/org_hornetq_api_core_client_client_session.rb
jruby-hornetq-0.2.1.alpha	lib/hornetq/client/org_hornetq_api_core_client_client_session.rb