org.apache.qpid.server.output
Interface ProtocolOutputConverter

All Known Implementing Classes:
ProtocolOutputConverterImpl, ProtocolOutputConverterImpl, ProtocolOutputConverterImpl

public interface ProtocolOutputConverter


Nested Class Summary
static interface ProtocolOutputConverter.Factory
           
 
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)
           
 

Method Detail

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