org.apache.qpid.client
Class AMQSession.Dispatcher

java.lang.Object
  extended by 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.


Constructor Summary
AMQSession.Dispatcher()
           
 
Method Summary
 void close()
           
(package private)  boolean connectionStopped()
           
 void recover()
           
 void rejectPending(C consumer)
           
 void rollback()
           
 void run()
           
(package private)  boolean setConnectionStopped(boolean connectionStopped)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AMQSession.Dispatcher

public AMQSession.Dispatcher()
Method Detail

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