org.apache.qpid.server.cluster.handler
Class ClusterMethodHandler<A extends org.apache.qpid.framing.AMQMethodBody>

java.lang.Object
  extended by org.apache.qpid.server.cluster.handler.ClusterMethodHandler<A>
All Implemented Interfaces:
org.apache.qpid.server.state.StateAwareMethodListener<A>
Direct Known Subclasses:
ChainedClusterMethodHandler, PeerHandler, ReplicatingConsumeHandler

public abstract class ClusterMethodHandler<A extends org.apache.qpid.framing.AMQMethodBody>
extends java.lang.Object
implements org.apache.qpid.server.state.StateAwareMethodListener<A>


Constructor Summary
ClusterMethodHandler()
           
 
Method Summary
protected abstract  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)
           
 void methodReceived(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 abstract  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
 

Constructor Detail

ClusterMethodHandler

public ClusterMethodHandler()
Method Detail

methodReceived

public final void methodReceived(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:
methodReceived in interface org.apache.qpid.server.state.StateAwareMethodListener<A extends org.apache.qpid.framing.AMQMethodBody>
Throws:
org.apache.qpid.AMQException

peer

protected abstract 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
Throws:
org.apache.qpid.AMQException

client

protected abstract 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
Throws:
org.apache.qpid.AMQException