Package org.objectweb.joram.client.jms.connection

Class Requestor

java.lang.Object

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

All Implemented Interfaces:

ErrorListener, ReplyListener

public class Requestor
extends Object
implements ReplyListener, ErrorListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	Requestor.Status

Field Summary

Fields

Modifier and Type	Field	Description
private static boolean	DEBUG
static String	DEFAULT_REQUEST_TIMEOUT_PROPERTY
static long	DEFAULT_REQUEST_TIMEOUT_VALUE
private long	defaultRequestTimeout
private static Logger	logger
private RequestMultiplexer	mtpx
private Object	reply
private int	requestId
private int	status

Constructor Summary

Constructors

Constructor	Description
Requestor(RequestMultiplexer mtpx)

Method Summary

Modifier and Type	Method	Description
void	abortRequest()
void	close()
void	errorReceived(int replyId, MomExceptionReply exc)
int	getRequestId()
private void	init()
void	replyAborted(int replyId)
boolean	replyReceived(AbstractJmsReply reply)
AbstractJmsReply	request(AbstractJmsRequest request)
AbstractJmsReply	request(AbstractJmsRequest request, long timeout, CompletionListener completionListener)	Method sending a synchronous request to the server and waiting for an answer.
AbstractJmsReply	request(AbstractJmsRequest request, CompletionListener completionListener)
private void	setStatus(int status)
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

private static Logger logger

DEBUG

private static final boolean DEBUG

DEFAULT_REQUEST_TIMEOUT_PROPERTY

public static final String DEFAULT_REQUEST_TIMEOUT_PROPERTY

See Also:

Constant Field Values

DEFAULT_REQUEST_TIMEOUT_VALUE

public static final long DEFAULT_REQUEST_TIMEOUT_VALUE

See Also:

Constant Field Values

defaultRequestTimeout

private long defaultRequestTimeout

mtpx

private RequestMultiplexer mtpx

reply

private Object reply

requestId

private int requestId

status

private int status

Constructor Detail

Requestor

public Requestor(RequestMultiplexer mtpx)

Method Detail

setStatus

private void setStatus(int status)

getRequestId

public final int getRequestId()

init

private void init()

request

public AbstractJmsReply request(AbstractJmsRequest request)
                         throws JMSException

Throws:

JMSException

request

public AbstractJmsReply request(AbstractJmsRequest request,
                                CompletionListener completionListener)
                         throws JMSException

Throws:

JMSException

request

public AbstractJmsReply request(AbstractJmsRequest request,
                                long timeout,
                                CompletionListener completionListener)
                         throws JMSException

Method sending a synchronous request to the server and waiting for an answer.

Throws:

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.

JMSException - If the request failed for any other reason.

replyReceived

public boolean replyReceived(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,
                          MomExceptionReply exc)

Specified by:

errorReceived in interface ErrorListener

Specified by:

errorReceived in interface ReplyListener

replyAborted

public void replyAborted(int replyId)

Specified by:

replyAborted in interface ReplyListener

abortRequest

public void abortRequest()

close

public void close()

start

public void start()

stop

public void stop()