org.apache.qpid.server.output
Interface ProtocolOutputConverter
- All Known Implementing Classes:
- ProtocolOutputConverterImpl, ProtocolOutputConverterImpl, ProtocolOutputConverterImpl
public interface ProtocolOutputConverter
Method Summary |
void |
confirmConsumerAutoClose(int channelId,
org.apache.qpid.framing.AMQShortString consumerTag)
|
byte |
getProtocolMajorVersion()
|
byte |
getProtocolMinorVersion()
|
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 message,
int channelId,
long deliveryTag,
int queueSize)
|
void |
writeReturn(org.apache.qpid.framing.abstraction.MessagePublishInfo messagePublishInfo,
org.apache.qpid.framing.ContentHeaderBody header,
MessageContentSource msgContent,
int channelId,
int replyCode,
org.apache.qpid.framing.AMQShortString replyText)
|
confirmConsumerAutoClose
void confirmConsumerAutoClose(int channelId,
org.apache.qpid.framing.AMQShortString consumerTag)
writeDeliver
void writeDeliver(QueueEntry entry,
int channelId,
long deliveryTag,
org.apache.qpid.framing.AMQShortString consumerTag)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
writeGetOk
void writeGetOk(QueueEntry message,
int channelId,
long deliveryTag,
int queueSize)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
getProtocolMinorVersion
byte getProtocolMinorVersion()
getProtocolMajorVersion
byte getProtocolMajorVersion()
writeReturn
void writeReturn(org.apache.qpid.framing.abstraction.MessagePublishInfo messagePublishInfo,
org.apache.qpid.framing.ContentHeaderBody header,
MessageContentSource msgContent,
int channelId,
int replyCode,
org.apache.qpid.framing.AMQShortString replyText)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
writeFrame
void writeFrame(org.apache.qpid.framing.AMQDataBlock block)
Licensed to the Apache Software Foundation