org.apache.qpid.server.cluster.handler
Class ChainedClusterMethodHandler<A extends org.apache.qpid.framing.AMQMethodBody>
java.lang.Object
org.apache.qpid.server.cluster.handler.ClusterMethodHandler<A>
org.apache.qpid.server.cluster.handler.ChainedClusterMethodHandler<A>
- All Implemented Interfaces:
- org.apache.qpid.server.state.StateAwareMethodListener<A>
public class ChainedClusterMethodHandler<A extends org.apache.qpid.framing.AMQMethodBody>
- extends ClusterMethodHandler<A>
Method Summary |
protected void |
client(org.apache.qpid.server.state.AMQStateManager stateMgr,
org.apache.qpid.server.queue.QueueRegistry queues,
org.apache.qpid.server.exchange.ExchangeRegistry exchanges,
org.apache.qpid.server.protocol.AMQProtocolSession session,
org.apache.qpid.server.protocol.AMQMethodEvent<A> evt)
|
protected void |
peer(org.apache.qpid.server.state.AMQStateManager stateMgr,
org.apache.qpid.server.queue.QueueRegistry queues,
org.apache.qpid.server.exchange.ExchangeRegistry exchanges,
org.apache.qpid.server.protocol.AMQProtocolSession session,
org.apache.qpid.server.protocol.AMQMethodEvent<A> evt)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ChainedClusterMethodHandler
public ChainedClusterMethodHandler(java.util.List<ClusterMethodHandler<A>> handlers)
ChainedClusterMethodHandler
public ChainedClusterMethodHandler(ClusterMethodHandler<A>... handlers)
peer
protected final void peer(org.apache.qpid.server.state.AMQStateManager stateMgr,
org.apache.qpid.server.queue.QueueRegistry queues,
org.apache.qpid.server.exchange.ExchangeRegistry exchanges,
org.apache.qpid.server.protocol.AMQProtocolSession session,
org.apache.qpid.server.protocol.AMQMethodEvent<A> evt)
throws org.apache.qpid.AMQException
- Specified by:
peer
in class ClusterMethodHandler<A extends org.apache.qpid.framing.AMQMethodBody>
- Throws:
org.apache.qpid.AMQException
client
protected final void client(org.apache.qpid.server.state.AMQStateManager stateMgr,
org.apache.qpid.server.queue.QueueRegistry queues,
org.apache.qpid.server.exchange.ExchangeRegistry exchanges,
org.apache.qpid.server.protocol.AMQProtocolSession session,
org.apache.qpid.server.protocol.AMQMethodEvent<A> evt)
throws org.apache.qpid.AMQException
- Specified by:
client
in class ClusterMethodHandler<A extends org.apache.qpid.framing.AMQMethodBody>
- Throws:
org.apache.qpid.AMQException