public interface ProtocolOutputConverter
Modifier and Type | Method and Description |
---|---|
void |
confirmConsumerAutoClose(int channelId,
AMQShortString consumerTag) |
long |
writeDeliver(ServerMessage msg,
InstanceProperties props,
int channelId,
long deliveryTag,
AMQShortString consumerTag) |
void |
writeFrame(AMQDataBlock block) |
long |
writeGetOk(ServerMessage msg,
InstanceProperties props,
int channelId,
long deliveryTag,
int queueSize) |
void |
writeReturn(MessagePublishInfo messagePublishInfo,
ContentHeaderBody header,
MessageContentSource msgContent,
int channelId,
int replyCode,
AMQShortString replyText) |
void confirmConsumerAutoClose(int channelId, AMQShortString consumerTag)
long writeDeliver(ServerMessage msg, InstanceProperties props, int channelId, long deliveryTag, AMQShortString consumerTag)
long writeGetOk(ServerMessage msg, InstanceProperties props, int channelId, long deliveryTag, int queueSize)
void writeReturn(MessagePublishInfo messagePublishInfo, ContentHeaderBody header, MessageContentSource msgContent, int channelId, int replyCode, AMQShortString replyText)
void writeFrame(AMQDataBlock block)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.