org.apache.qpid.framing

Class ContentBody

java.lang.Object

org.apache.qpid.framing.ContentBody

All Implemented Interfaces:

AMQBody

public class ContentBody
extends Object
implements AMQBody

Field Summary

Fields

Modifier and Type	Field and Description
static byte	TYPE

Constructor Summary

Constructors

Constructor and Description
ContentBody()
ContentBody(byte[] payload)
ContentBody(DataInput buffer, long size)

Method Summary

Methods

Modifier and Type	Method and Description
static AMQFrame	createAMQFrame(int channelId, ByteBuffer buf, int offset, int length)
static AMQFrame	createAMQFrame(int channelId, ContentBody body)
byte	getFrameType()
byte[]	getPayload()
int	getSize() Get the size of the body
void	handle(int channelId, AMQVersionAwareProtocolSession session)
protected void	populateFromBuffer(DataInputStream buffer, long size)
void	reduceBufferToFit()
void	writePayload(DataOutput buffer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TYPE

public static final byte TYPE

See Also:

Constant Field Values

Constructor Detail

ContentBody

public ContentBody()

ContentBody

public ContentBody(DataInput buffer,
           long size)
            throws AMQFrameDecodingException,
                   IOException

Throws:

AMQFrameDecodingException

IOException

ContentBody

public ContentBody(byte[] payload)

Method Detail

getFrameType

public byte getFrameType()

Specified by:

getFrameType in interface AMQBody

getSize

public int getSize()

Description copied from interface: AMQBody

Get the size of the body

Specified by:

getSize in interface AMQBody

Returns:

unsigned short

writePayload

public void writePayload(DataOutput buffer)
                  throws IOException

Specified by:

writePayload in interface AMQBody

Throws:

IOException

handle

public void handle(int channelId,
          AMQVersionAwareProtocolSession session)
            throws AMQException

Specified by:

handle in interface AMQBody

Throws:

AMQException

populateFromBuffer

protected void populateFromBuffer(DataInputStream buffer,
                      long size)
                           throws AMQFrameDecodingException,
                                  IOException

Throws:

AMQFrameDecodingException

IOException

reduceBufferToFit

public void reduceBufferToFit()

getPayload

public byte[] getPayload()

createAMQFrame

public static AMQFrame createAMQFrame(int channelId,
                      ByteBuffer buf,
                      int offset,
                      int length)

createAMQFrame

public static AMQFrame createAMQFrame(int channelId,
                      ContentBody body)