org.objectweb.joram.client.jms.connection
Class RequestMultiplexer
java.lang.Object
org.objectweb.joram.client.jms.connection.RequestMultiplexer
public class RequestMultiplexer
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
requestsTable
public java.util.Hashtable requestsTable
RequestMultiplexer
public RequestMultiplexer(Connection cnx,
RequestChannel channel,
long heartBeat)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
isClosed
public boolean isClosed()
closing
public void closing()
setExceptionListener
public void setExceptionListener(javax.jms.ExceptionListener exceptionListener)
getExceptionListener
public javax.jms.ExceptionListener getExceptionListener()
sendRequest
public void sendRequest(AbstractJmsRequest request)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
sendRequest
public void sendRequest(AbstractJmsRequest request,
ReplyListener listener)
throws javax.jms.JMSException
- Throws:
javax.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()
- Used by:
1- close()
2- the connector layer (OutboundConnection.cleanup())
abortRequest
public void abortRequest(int requestId)
- Not synchronized because it would possibly
deadlock with some reply listeners
(actually requestors).
deny
public void deny(ConsumerMessages messages)
schedule
public void schedule(java.util.TimerTask task,
long period)
setDemultiplexerDaemonName
public void setDemultiplexerDaemonName(java.lang.String name)
getDemultiplexerDaemonName
public java.lang.String getDemultiplexerDaemonName()
Copyright © 2011 ScalAgent D.T.. All Rights Reserved.