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