org.apache.qpid.client
Class AMQSession.Dispatcher
java.lang.Object
org.apache.qpid.client.AMQSession.Dispatcher
- All Implemented Interfaces:
- Runnable
- Enclosing class:
- AMQSession<C extends BasicMessageConsumer,P extends BasicMessageProducer>
class AMQSession.Dispatcher
- extends Object
- implements Runnable
Responsible for decoding a message fragment and passing it to the appropriate message consumer.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AMQSession.Dispatcher
public AMQSession.Dispatcher()
close
public void close()
rejectPending
public void rejectPending(C consumer)
rollback
public void rollback()
recover
public void recover()
run
public void run()
- Specified by:
run
in interface Runnable
connectionStopped
final boolean connectionStopped()
setConnectionStopped
boolean setConnectionStopped(boolean connectionStopped)
Licensed to the Apache Software Foundation