org.objectweb.joram.client.jms.connection.RequestMultiplexer Class Reference

Collaboration diagram for org.objectweb.joram.client.jms.connection.RequestMultiplexer:

[legend]List of all members.

Public Member Functions
	RequestMultiplexer (Connection cnx, RequestChannel channel, long heartBeat) throws JMSException
boolean	isClosed ()
void	setExceptionListener (javax.jms.ExceptionListener exceptionListener)
javax.jms.ExceptionListener	getExceptionListener ()
void	sendRequest (AbstractJmsRequest request) throws JMSException
void	sendRequest (AbstractJmsRequest request, ReplyListener listener) throws JMSException
void	setMultiThreadSync (int delay, int threshold)
void	close ()
void	cleanup ()
void	abortRequest (int requestId)
void	deny (ConsumerMessages messages)
void	schedule (TimerTask task, long period)
void	setDemultiplexerDaemonName (String name)
String	getDemultiplexerDaemonName ()
Public Attributes
Hashtable	requestsTable
Classes
class	onExceptionRunner

---

Detailed Description

Definition at line 47 of file RequestMultiplexer.java.

---

Member Function Documentation

void org.objectweb.joram.client.jms.connection.RequestMultiplexer.close

(

)

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

Definition at line 189 of file RequestMultiplexer.java.

References org.objectweb.joram.client.jms.connection.RequestMultiplexer.cleanup(), org.objectweb.joram.client.jms.connection.RequestChannel.close(), and org.objectweb.joram.client.jms.connection.RequestMultiplexer.requestsTable.

Referenced by org.objectweb.joram.client.jms.Connection.doClose().

Here is the call graph for this function:

void org.objectweb.joram.client.jms.connection.RequestMultiplexer.cleanup

(

)

Used by: 1- close() 2- the connector layer (OutboundConnection.cleanup())

Definition at line 225 of file RequestMultiplexer.java.

References org.objectweb.joram.client.jms.connection.RequestMultiplexer.requestsTable.

Referenced by org.objectweb.joram.client.jms.Connection.cleanup(), and org.objectweb.joram.client.jms.connection.RequestMultiplexer.close().

void org.objectweb.joram.client.jms.connection.RequestMultiplexer.abortRequest

(

int

requestId

)

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

Definition at line 250 of file RequestMultiplexer.java.

References org.objectweb.joram.client.jms.connection.ReplyListener.replyAborted().

Referenced by org.objectweb.joram.client.jms.connection.Requestor.abortRequest(), org.objectweb.joram.client.jms.MessageConsumerListener.close(), and org.objectweb.joram.client.jms.connection.Requestor.request().

Here is the call graph for this function:

---

The documentation for this class was generated from the following file:

• org/objectweb/joram/client/jms/connection/RequestMultiplexer.java

---