org.apache.qpid.protocol
Interface AMQVersionAwareProtocolSession

All Superinterfaces:
AMQProtocolWriter, ProtocolVersionAware

public interface AMQVersionAwareProtocolSession
extends AMQProtocolWriter, ProtocolVersionAware

AMQVersionAwareProtocolSession is implemented by all AMQP session classes, that need to provide an awareness to callers of the version of the AMQP protocol that they are able to work with.

CRC Card
Responsibilities
Provide the method registry for a specific version of the AMQP.

Todo:
Why is this a seperate interface to ProtocolVersionAware, could they be combined into a single interface and one of them eliminated? Move getRegistry method to ProtocolVersionAware, make the sessions implement AMQProtocolWriter directly and drop this interface.

Method Summary
 void contentBodyReceived(int channelId, ContentBody body)
           
 void contentHeaderReceived(int channelId, ContentHeaderBody body)
           
 MethodRegistry getMethodRegistry()
          Gets the method registry for a specific version of the AMQP.
 void heartbeatBodyReceived(int channelId, HeartbeatBody body)
           
 void init()
           
 void methodFrameReceived(int channelId, AMQMethodBody body)
           
 void setSender(Sender<ByteBuffer> sender)
           
 
Methods inherited from interface org.apache.qpid.protocol.AMQProtocolWriter
writeFrame
 
Methods inherited from interface org.apache.qpid.protocol.ProtocolVersionAware
getProtocolMajorVersion, getProtocolMinorVersion, getProtocolVersion
 

Method Detail

getMethodRegistry

MethodRegistry getMethodRegistry()
Gets the method registry for a specific version of the AMQP.

Returns:
The method registry for a specific version of the AMQP.

methodFrameReceived

void methodFrameReceived(int channelId,
                         AMQMethodBody body)
                         throws AMQException
Throws:
AMQException

contentHeaderReceived

void contentHeaderReceived(int channelId,
                           ContentHeaderBody body)
                           throws AMQException
Throws:
AMQException

contentBodyReceived

void contentBodyReceived(int channelId,
                         ContentBody body)
                         throws AMQException
Throws:
AMQException

heartbeatBodyReceived

void heartbeatBodyReceived(int channelId,
                           HeartbeatBody body)
                           throws AMQException
Throws:
AMQException

setSender

void setSender(Sender<ByteBuffer> sender)

init

void init()


Licensed to the Apache Software Foundation