org.apache.qpid.server.output.amqp0_8
Class ProtocolOutputConverterImpl

java.lang.Object
  extended by org.apache.qpid.server.output.amqp0_8.ProtocolOutputConverterImpl
All Implemented Interfaces:
ProtocolOutputConverter

public class ProtocolOutputConverterImpl
extends Object
implements ProtocolOutputConverter


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.output.ProtocolOutputConverter
ProtocolOutputConverter.Factory
 
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 content, 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
 

Method Detail

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 content,
                        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