org.apache.qpid.server.output.amqp0_9
Class ProtocolOutputConverterImpl
java.lang.Object
org.apache.qpid.server.output.amqp0_9.ProtocolOutputConverterImpl
- All Implemented Interfaces:
- ProtocolOutputConverter
public class ProtocolOutputConverterImpl
- extends Object
- implements ProtocolOutputConverter
Method Summary |
void |
confirmConsumerAutoClose(int channelId,
org.apache.qpid.framing.AMQShortString consumerTag)
|
static ProtocolOutputConverter.Factory |
getInstanceFactory()
|
byte |
getProtocolMajorVersion()
|
byte |
getProtocolMinorVersion()
|
AMQProtocolSession |
getProtocolSession()
|
void |
writeDeliver(QueueEntry entry,
int channelId,
long deliveryTag,
org.apache.qpid.framing.AMQShortString consumerTag)
|
void |
writeFrame(org.apache.qpid.framing.AMQDataBlock block)
|
void |
writeGetOk(QueueEntry entry,
int channelId,
long deliveryTag,
int queueSize)
|
void |
writeReturn(org.apache.qpid.framing.abstraction.MessagePublishInfo messagePublishInfo,
org.apache.qpid.framing.ContentHeaderBody header,
MessageContentSource message,
int channelId,
int replyCode,
org.apache.qpid.framing.AMQShortString replyText)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
getInstanceFactory
public static ProtocolOutputConverter.Factory getInstanceFactory()
getProtocolSession
public AMQProtocolSession getProtocolSession()
writeDeliver
public void writeDeliver(QueueEntry entry,
int channelId,
long deliveryTag,
org.apache.qpid.framing.AMQShortString consumerTag)
throws org.apache.qpid.AMQException
- Specified by:
writeDeliver
in interface ProtocolOutputConverter
- Throws:
org.apache.qpid.AMQException
writeGetOk
public void writeGetOk(QueueEntry entry,
int channelId,
long deliveryTag,
int queueSize)
throws org.apache.qpid.AMQException
- Specified by:
writeGetOk
in interface ProtocolOutputConverter
- Throws:
org.apache.qpid.AMQException
getProtocolMinorVersion
public byte getProtocolMinorVersion()
- Specified by:
getProtocolMinorVersion
in interface ProtocolOutputConverter
getProtocolMajorVersion
public byte getProtocolMajorVersion()
- Specified by:
getProtocolMajorVersion
in interface ProtocolOutputConverter
writeReturn
public void writeReturn(org.apache.qpid.framing.abstraction.MessagePublishInfo messagePublishInfo,
org.apache.qpid.framing.ContentHeaderBody header,
MessageContentSource message,
int channelId,
int replyCode,
org.apache.qpid.framing.AMQShortString replyText)
throws org.apache.qpid.AMQException
- Specified by:
writeReturn
in interface ProtocolOutputConverter
- Throws:
org.apache.qpid.AMQException
writeFrame
public void writeFrame(org.apache.qpid.framing.AMQDataBlock block)
- Specified by:
writeFrame
in interface ProtocolOutputConverter
confirmConsumerAutoClose
public void confirmConsumerAutoClose(int channelId,
org.apache.qpid.framing.AMQShortString consumerTag)
- Specified by:
confirmConsumerAutoClose
in interface ProtocolOutputConverter
Licensed to the Apache Software Foundation