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

java.lang.Object
  extended by org.apache.qpid.server.cluster.handler.ClusterMethodHandler<A>
      extended by org.apache.qpid.server.cluster.handler.PeerHandler<A>
All Implemented Interfaces:
org.apache.qpid.server.state.StateAwareMethodListener<A>

public class PeerHandler<A extends org.apache.qpid.framing.AMQMethodBody>
extends ClusterMethodHandler<A>

Base for implementing handlers that carry out different actions based on whether the method they are handling was sent by a peer (i.e. another broker in the cluster) or a client (i.e. an end-user application).


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 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
 

Method Detail

peer

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)
             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 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