org.apache.qpid.server.cluster
Class ClusteredProtocolSession

java.lang.Object
  extended by org.apache.qpid.server.protocol.AMQMinaProtocolSession
      extended by org.apache.qpid.server.cluster.ClusteredProtocolSession
All Implemented Interfaces:
org.apache.qpid.framing.ProtocolVersionList, org.apache.qpid.server.management.Managable, org.apache.qpid.server.protocol.AMQProtocolSession

public class ClusteredProtocolSession
extends org.apache.qpid.server.protocol.AMQMinaProtocolSession


Field Summary
 
Fields inherited from interface org.apache.qpid.framing.ProtocolVersionList
PROTOCOL_MAJOR, PROTOCOL_MINOR, pv
 
Constructor Summary
ClusteredProtocolSession(org.apache.mina.common.IoSession session, org.apache.qpid.server.queue.QueueRegistry queueRegistry, org.apache.qpid.server.exchange.ExchangeRegistry exchangeRegistry, org.apache.qpid.codec.AMQCodecFactory codecFactory, org.apache.qpid.server.state.AMQStateManager stateManager)
           
 
Method Summary
static boolean canRelay(org.apache.qpid.server.queue.AMQMessage payload, MemberHandle target)
           
 org.apache.qpid.server.AMQChannel getChannel(int channelId)
           
 MemberHandle getSessionPeer()
           
static MemberHandle getSessionPeer(org.apache.qpid.server.protocol.AMQProtocolSession session)
           
static MemberHandle getSessionPeer(org.apache.mina.common.IoSession session)
           
static boolean isPayloadFromPeer(org.apache.qpid.server.queue.AMQMessage payload)
           
 boolean isPeerSession()
           
static boolean isPeerSession(org.apache.qpid.server.protocol.AMQProtocolSession session)
           
static boolean isPeerSession(org.apache.mina.common.IoSession session)
           
static void setSessionPeer(org.apache.qpid.server.protocol.AMQProtocolSession session, MemberHandle peer)
           
 void setSessionPeer(MemberHandle peer)
           
 
Methods inherited from class org.apache.qpid.server.protocol.AMQMinaProtocolSession
addChannel, amqpVersionEquals, closeChannel, closeSession, dataBlockReceived, dump, getAmqpMajor, getAmqpMinor, getAMQProtocolSession, getContextKey, getKey, getLocalFQDN, getManagedObject, getSaslServer, initHeartbeats, removeChannel, setContextKey, setSaslServer, toString, writeFrame
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ClusteredProtocolSession

public ClusteredProtocolSession(org.apache.mina.common.IoSession session,
                                org.apache.qpid.server.queue.QueueRegistry queueRegistry,
                                org.apache.qpid.server.exchange.ExchangeRegistry exchangeRegistry,
                                org.apache.qpid.codec.AMQCodecFactory codecFactory,
                                org.apache.qpid.server.state.AMQStateManager stateManager)
                         throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException
Method Detail

isPeerSession

public boolean isPeerSession()

setSessionPeer

public void setSessionPeer(MemberHandle peer)

getSessionPeer

public MemberHandle getSessionPeer()

getChannel

public org.apache.qpid.server.AMQChannel getChannel(int channelId)
                                             throws org.apache.qpid.AMQException
Specified by:
getChannel in interface org.apache.qpid.server.protocol.AMQProtocolSession
Overrides:
getChannel in class org.apache.qpid.server.protocol.AMQMinaProtocolSession
Throws:
org.apache.qpid.AMQException

isPeerSession

public static boolean isPeerSession(org.apache.mina.common.IoSession session)

isPeerSession

public static boolean isPeerSession(org.apache.qpid.server.protocol.AMQProtocolSession session)

setSessionPeer

public static void setSessionPeer(org.apache.qpid.server.protocol.AMQProtocolSession session,
                                  MemberHandle peer)

getSessionPeer

public static MemberHandle getSessionPeer(org.apache.qpid.server.protocol.AMQProtocolSession session)

getSessionPeer

public static MemberHandle getSessionPeer(org.apache.mina.common.IoSession session)

isPayloadFromPeer

public static boolean isPayloadFromPeer(org.apache.qpid.server.queue.AMQMessage payload)

canRelay

public static boolean canRelay(org.apache.qpid.server.queue.AMQMessage payload,
                               MemberHandle target)