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
Method Summary |
void |
abortRequest(int requestId)
Not synchronized because it would possibly
deadlock with some reply listeners
(actually requestors). |
void |
cleanup()
Used by Connection clean up. |
void |
close()
Not synchronized because it would possibly
deadlock with some reply listeners
(actually requestors). |
void |
deny(org.objectweb.joram.shared.client.ConsumerMessages messages)
|
javax.jms.ExceptionListener |
getExceptionListener()
|
boolean |
isClosed()
|
void |
schedule(fr.dyade.aaa.util.TimerTask task,
long period)
|
void |
sendRequest(org.objectweb.joram.shared.client.AbstractJmsRequest request)
|
void |
sendRequest(org.objectweb.joram.shared.client.AbstractJmsRequest request,
ReplyListener listener)
|
void |
setExceptionListener(javax.jms.ExceptionListener exceptionListener)
|
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(RequestChannel channel,
long heartBeat,
java.lang.String cnxId)
throws javax.jms.JMSException
isClosed
public boolean isClosed()
setExceptionListener
public void setExceptionListener(javax.jms.ExceptionListener exceptionListener)
getExceptionListener
public javax.jms.ExceptionListener getExceptionListener()
sendRequest
public void sendRequest(org.objectweb.joram.shared.client.AbstractJmsRequest request)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
sendRequest
public void sendRequest(org.objectweb.joram.shared.client.AbstractJmsRequest request,
ReplyListener listener)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
close
public void close()
- Not synchronized because it would possibly
deadlock with some reply listeners
(actually requestors).
cleanup
public void cleanup()
- Used by Connection clean up.
It's a very specific usage linked to
the connector layer.
abortRequest
public void abortRequest(int requestId)
- Not synchronized because it would possibly
deadlock with some reply listeners
(actually requestors).
deny
public void deny(org.objectweb.joram.shared.client.ConsumerMessages messages)
schedule
public void schedule(fr.dyade.aaa.util.TimerTask task,
long period)
Copyright ? 2005 Scalagent - All rights reserved