Joram ${version}

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

java.lang.Object
  extended byorg.objectweb.joram.client.jms.connection.RequestMultiplexer

public class RequestMultiplexer
extends java.lang.Object


Field Summary
 java.util.Hashtable requestsTable
           
 
Constructor Summary
RequestMultiplexer(RequestChannel channel, long heartBeat, java.lang.String cnxId)
           
 
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(ConsumerMessages messages)
           
 javax.jms.ExceptionListener getExceptionListener()
           
 boolean isClosed()
           
 void schedule(fr.dyade.aaa.util.TimerTask task, long period)
           
 void sendRequest(AbstractJmsRequest request)
           
 void sendRequest(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
 

Field Detail

requestsTable

public java.util.Hashtable requestsTable
Constructor Detail

RequestMultiplexer

public RequestMultiplexer(RequestChannel channel,
                          long heartBeat,
                          java.lang.String cnxId)
                   throws javax.jms.JMSException
Method Detail

isClosed

public boolean isClosed()

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

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(ConsumerMessages messages)

schedule

public void schedule(fr.dyade.aaa.util.TimerTask task,
                     long period)

Joram ${version}

Copyright © 2005 Scalagent - All rights reserved