Package org.ow2.joram.jakarta.jms.connection

Class RequestMultiplexer

java.lang.Object

org.ow2.joram.jakarta.jms.connection.RequestMultiplexer

public class RequestMultiplexer
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	RequestMultiplexer.Closer
private class	RequestMultiplexer.DemultiplexerDaemon
private class	RequestMultiplexer.HeartBeatTask	Timer task responsible for sending a ping message to the server if no request has been sent during the specified timeout ('cnxPendingTimer' from the factory parameters).
(package private) class	RequestMultiplexer.onExceptionRunner
private static class	RequestMultiplexer.Status

Field Summary

Fields

Modifier and Type	Field	Description
private RequestChannel	channel
private Connection	cnx
private Map<Integer,CompletionListener>	completionListeners
private static boolean	DEBUG
private RequestMultiplexer.DemultiplexerDaemon	demtpx
private jakarta.jms.ExceptionListener	exceptionListener
private RequestMultiplexer.HeartBeatTask	heartBeatTask	The task responsible for keeping the connection alive.
private long	lastRequestDate	The date of the last request
private static Logger	logger
private int	requestCounter
private Map<Integer,ReplyListener>	requestsTable
(package private) CompletionListener	runningCL
private int	status
private static Timer	timer
private static int	timerInUse

Constructor Summary

Constructors

Constructor	Description
RequestMultiplexer(Connection cnx, RequestChannel channel, long heartBeat)

Method Summary

Modifier and Type	Method	Description
private void	abortReply(AbstractJmsReply reply)
void	abortRequest(int requestId)	Not synchronized because it would possibly deadlock with some reply listeners (actually requestors).
static jakarta.jms.JMSException	buildJmsException(MomExceptionReply excReply)	Converts a MomExceptionReply to the corresponding JMSException.
private static void	cancelTimer()
boolean	checkCLMessageProducer(Session session, MessageProducer mp)
boolean	checkCLSession(Session session)
boolean	checkDemultiplexerDaemon()
void	cleanup()	Aborts all running requests.
void	close()	Not synchronized because it would possibly deadlock with some reply listeners (actually requestors).
void	closing()
private static void	createTimer()
void	deny(ConsumerMessages messages)
void	denyRequest(ConsumerReceiveRequest request)
private ReplyListener	doAbortRequest(int requestId)
String	getDemultiplexerDaemonName()
jakarta.jms.ExceptionListener	getExceptionListener()
private static Timer	getTimer()
boolean	isClosed()
private void	onException(Exception exc)
void	replyAllError(MomExceptionReply exc)
private void	route(AbstractJmsReply reply, boolean isCompletionListener)	Not synchronized because it may be called by the demultiplexer during a concurrent close.
void	schedule(TimerTask task, long period)
void	sendRequest(AbstractJmsRequest request)
void	sendRequest(AbstractJmsRequest request, ReplyListener listener, CompletionListener completionListener)
void	setDemultiplexerDaemonName(String name)
void	setExceptionListener(jakarta.jms.ExceptionListener exceptionListener)
void	setMultiThreadSync(int delay, int threshold)
private void	setStatus(int status)

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

cnx

private Connection cnx

status

private volatile int status

channel

private RequestChannel channel

requestsTable

private Map<Integer,ReplyListener> requestsTable

completionListeners

private Map<Integer,CompletionListener> completionListeners

requestCounter

private int requestCounter

demtpx

private RequestMultiplexer.DemultiplexerDaemon demtpx

timer

private static Timer timer

timerInUse

private static int timerInUse

heartBeatTask

private RequestMultiplexer.HeartBeatTask heartBeatTask

The task responsible for keeping the connection alive.

exceptionListener

private jakarta.jms.ExceptionListener exceptionListener

lastRequestDate

private volatile long lastRequestDate

The date of the last request

runningCL

CompletionListener runningCL

Constructor Detail

RequestMultiplexer

public RequestMultiplexer(Connection cnx,
                          RequestChannel channel,
                          long heartBeat)
                   throws jakarta.jms.JMSException

Throws:

jakarta.jms.JMSException

Method Detail

buildJmsException

public static jakarta.jms.JMSException buildJmsException(MomExceptionReply excReply)

Converts a MomExceptionReply to the corresponding JMSException.

Parameters:

excReply - the MOM reply to convert

Returns:

the corresponding Exception

checkDemultiplexerDaemon

public boolean checkDemultiplexerDaemon()

checkCLSession

public boolean checkCLSession(Session session)

checkCLMessageProducer

public boolean checkCLMessageProducer(Session session,
                                      MessageProducer mp)

createTimer

private static void createTimer()

cancelTimer

private static void cancelTimer()

getTimer

private static Timer getTimer()

setStatus

private void setStatus(int status)

isClosed

public boolean isClosed()

closing

public void closing()

setExceptionListener

public void setExceptionListener(jakarta.jms.ExceptionListener exceptionListener)

getExceptionListener

public jakarta.jms.ExceptionListener getExceptionListener()

sendRequest

public void sendRequest(AbstractJmsRequest request)
                 throws jakarta.jms.JMSException

Throws:

jakarta.jms.JMSException

sendRequest

public void sendRequest(AbstractJmsRequest request,
                        ReplyListener listener,
                        CompletionListener completionListener)
                 throws jakarta.jms.JMSException

Throws:

jakarta.jms.JMSException

setMultiThreadSync

public void setMultiThreadSync(int delay,
                               int threshold)

close

public void close()

Not synchronized because it would possibly deadlock with some reply listeners (actually requestors).

cleanup

public void cleanup()

Aborts all running requests. Used by: 1- close() 2- the connector layer (OutboundConnection.cleanup())

replyAllError

public void replyAllError(MomExceptionReply exc)

abortRequest

public void abortRequest(int requestId)

Not synchronized because it would possibly deadlock with some reply listeners (actually requestors).

doAbortRequest

private ReplyListener doAbortRequest(int requestId)

route

private void route(AbstractJmsReply reply,
                   boolean isCompletionListener)

Not synchronized because it may be called by the demultiplexer during a concurrent close. It would deadlock as the close waits for the demultiplexer to stop.

abortReply

private void abortReply(AbstractJmsReply reply)

deny

public void deny(ConsumerMessages messages)

denyRequest

public void denyRequest(ConsumerReceiveRequest request)

onException

private void onException(Exception exc)

schedule

public void schedule(TimerTask task,
                     long period)

setDemultiplexerDaemonName

public void setDemultiplexerDaemonName(String name)

getDemultiplexerDaemonName

public String getDemultiplexerDaemonName()