public class ProtocolOutputConverterImpl extends Object implements ProtocolOutputConverter
Modifier and Type | Class and Description |
---|---|
static class |
ProtocolOutputConverterImpl.CompositeAMQBodyBlock |
static class |
ProtocolOutputConverterImpl.SmallCompositeAMQBodyBlock |
Constructor and Description |
---|
ProtocolOutputConverterImpl(AMQPConnection_0_8 connection) |
Modifier and Type | Method and Description |
---|---|
void |
confirmConsumerAutoClose(int channelId,
AMQShortString consumerTag) |
long |
writeDeliver(ServerMessage m,
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 message,
int channelId,
int replyCode,
AMQShortString replyText) |
public ProtocolOutputConverterImpl(AMQPConnection_0_8 connection)
public long writeDeliver(ServerMessage m, InstanceProperties props, int channelId, long deliveryTag, AMQShortString consumerTag)
writeDeliver
in interface ProtocolOutputConverter
public long writeGetOk(ServerMessage msg, InstanceProperties props, int channelId, long deliveryTag, int queueSize)
writeGetOk
in interface ProtocolOutputConverter
public void writeReturn(MessagePublishInfo messagePublishInfo, ContentHeaderBody header, MessageContentSource message, int channelId, int replyCode, AMQShortString replyText)
writeReturn
in interface ProtocolOutputConverter
public void writeFrame(AMQDataBlock block)
writeFrame
in interface ProtocolOutputConverter
public void confirmConsumerAutoClose(int channelId, AMQShortString consumerTag)
confirmConsumerAutoClose
in interface ProtocolOutputConverter
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.