org.apache.qpid.server.cluster.handler
Class ReplicatingConsumeHandler
java.lang.Object
org.apache.qpid.server.cluster.handler.ClusterMethodHandler<A>
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
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_logger
protected static final org.apache.log4j.Logger _logger
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.