Joram ${version}

org.objectweb.joram.client.jms.connection
Class Requestor

java.lang.Object
  extended byorg.objectweb.joram.client.jms.connection.Requestor
All Implemented Interfaces:
ErrorListener, ReplyListener

public class Requestor
extends java.lang.Object
implements ReplyListener, ErrorListener


Constructor Summary
Requestor(RequestMultiplexer mtpx)
           
 
Method Summary
 void abortRequest()
           
 void close()
           
 void errorReceived(int replyId, javax.jms.JMSException exc)
           
 int getRequestId()
           
 void replyAborted(int replyId)
           
 boolean replyReceived(org.objectweb.joram.shared.client.AbstractJmsReply reply)
           
 org.objectweb.joram.shared.client.AbstractJmsReply request(org.objectweb.joram.shared.client.AbstractJmsRequest request)
           
 org.objectweb.joram.shared.client.AbstractJmsReply request(org.objectweb.joram.shared.client.AbstractJmsRequest request, long timeout)
          Method sending a synchronous request to the server and waiting for an answer.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Requestor

public Requestor(RequestMultiplexer mtpx)
Method Detail

getRequestId

public final int getRequestId()

request

public org.objectweb.joram.shared.client.AbstractJmsReply request(org.objectweb.joram.shared.client.AbstractJmsRequest request)
                                                           throws javax.jms.JMSException
Throws:
javax.jms.JMSException

request

public org.objectweb.joram.shared.client.AbstractJmsReply request(org.objectweb.joram.shared.client.AbstractJmsRequest request,
                                                                  long timeout)
                                                           throws javax.jms.JMSException
Method sending a synchronous request to the server and waiting for an answer.

Throws:
java.lang.IllegalStateException - If the connection is closed or broken, if the server state does not allow to process the request.
JMSSecurityException - When sending a request to a destination not accessible because of security.
InvalidDestinationException - When sending a request to a destination that no longer exists.
javax.jms.JMSException - If the request failed for any other reason.

replyReceived

public boolean replyReceived(org.objectweb.joram.shared.client.AbstractJmsReply reply)
                      throws AbortedRequestException
Specified by:
replyReceived in interface ReplyListener
Returns:
whether the request must be aborted or not.
Throws:
AbortedRequestException

errorReceived

public void errorReceived(int replyId,
                          javax.jms.JMSException exc)
Specified by:
errorReceived in interface ErrorListener

replyAborted

public void replyAborted(int replyId)
Specified by:
replyAborted in interface ReplyListener

abortRequest

public void abortRequest()

close

public void close()

Joram ${version}

Copyright ? 2005 Scalagent - All rights reserved