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.

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

Methods

Modifier and Type	Method and Description
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	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)