org.apache.qpid.server.cluster.handler
Class ReplicatingConsumeHandler

java.lang.Object
  extended by org.apache.qpid.server.cluster.handler.ClusterMethodHandler<A>
      extended by org.apache.qpid.server.cluster.handler.ReplicatingConsumeHandler
All Implemented Interfaces:
StandardPolicies, StateAwareMethodListener<org.apache.qpid.framing.BasicConsumeBody>

public class ReplicatingConsumeHandler
extends ClusterMethodHandler<A>


Field Summary
protected static org.apache.log4j.Logger _logger
           
 
Fields inherited from interface org.apache.qpid.server.cluster.policy.StandardPolicies
ASYNCH_POLICY, SYNCH_POLICY
 
Method Summary
protected  void client(AMQStateManager stateMgr, AMQMethodEvent<A> evt)
           
protected  boolean isShared(AMQQueue queue)
           
protected  void local(AMQStateManager stateMgr, AMQMethodEvent<A> evt)
           
protected  void peer(AMQStateManager stateManager, AMQMethodEvent<A> evt)
           
protected  void replicate(AMQStateManager stateManager, AMQMethodEvent<org.apache.qpid.framing.BasicConsumeBody> evt)
           
 
Methods inherited from class org.apache.qpid.server.cluster.handler.ClusterMethodHandler
methodReceived
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_logger

protected static final org.apache.log4j.Logger _logger
Method Detail

replicate

protected void replicate(AMQStateManager stateManager,
                         AMQMethodEvent<org.apache.qpid.framing.BasicConsumeBody> evt)
                  throws AMQException
Throws:
AMQException

isShared

protected boolean isShared(AMQQueue queue)

peer

protected void peer(AMQStateManager stateManager,
                    AMQMethodEvent<A> evt)
             throws AMQException
Specified by:
peer in class ClusterMethodHandler<A extends AMQMethodBody>
Throws:
AMQException

client

protected void client(AMQStateManager stateMgr,
                      AMQMethodEvent<A> evt)
               throws AMQException
Specified by:
client in class ClusterMethodHandler<A extends AMQMethodBody>
Throws:
AMQException

local

protected void local(AMQStateManager stateMgr,
                     AMQMethodEvent<A> evt)
              throws AMQException
Throws:
AMQException


Copyright © 2007. All Rights Reserved.