org.apache.qpid.framing

Class ContentHeaderBody

java.lang.Object

org.apache.qpid.framing.ContentHeaderBody

All Implemented Interfaces:

AMQBody

public class ContentHeaderBody
extends Object
implements AMQBody

Field Summary

Fields

Modifier and Type	Field and Description
static int	CLASS_ID
static byte	TYPE

Constructor Summary

Constructors

Constructor and Description
ContentHeaderBody(BasicContentHeaderProperties props)
ContentHeaderBody(BasicContentHeaderProperties props, long bodySize)
ContentHeaderBody(DataInput buffer, long size)

Method Summary

Methods

Modifier and Type	Method and Description
static AMQFrame	createAMQFrame(int channelId, BasicContentHeaderProperties properties, long bodySize)
static ContentHeaderBody	createFromBuffer(DataInputStream buffer, long size) Helper method that is used currently by the persistence layer.
long	getBodySize() unsigned long but java can't handle that anyway when allocating byte array
int	getClassId()
byte	getFrameType()
BasicContentHeaderProperties	getProperties()
int	getSize() Get the size of the body
int	getWeight()
void	handle(int channelId, AMQVersionAwareProtocolSession session)
static void	process(MarkableDataInput buffer, ChannelMethodProcessor methodProcessor, long size)
void	setBodySize(long bodySize)
void	setProperties(BasicContentHeaderProperties props)
String	toString()
void	writePayload(DataOutput buffer)

Methods inherited from class java.lang.Object

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

Field Detail

TYPE

public static final byte TYPE

See Also:

Constant Field Values

CLASS_ID

public static final int CLASS_ID

See Also:

Constant Field Values

Constructor Detail

ContentHeaderBody

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

Throws:

AMQFrameDecodingException

IOException

ContentHeaderBody

public ContentHeaderBody(BasicContentHeaderProperties props)

ContentHeaderBody

public ContentHeaderBody(BasicContentHeaderProperties props,
                 long bodySize)

Method Detail

getFrameType

public byte getFrameType()

Specified by:

getFrameType in interface AMQBody

createFromBuffer

public static ContentHeaderBody createFromBuffer(DataInputStream buffer,
                                 long size)
                                          throws AMQFrameDecodingException,
                                                 AMQProtocolVersionException,
                                                 IOException

Helper method that is used currently by the persistence layer.

Parameters:

buffer - buffer to decode

size - size of the body

Returns:

the decoded header body

Throws:

AMQFrameDecodingException - if there is a decoding issue

AMQProtocolVersionException - if there is a version issue

IOException - if there is an IO issue

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

createAMQFrame

public static AMQFrame createAMQFrame(int channelId,
                      BasicContentHeaderProperties properties,
                      long bodySize)

getProperties

public BasicContentHeaderProperties getProperties()

setProperties

public void setProperties(BasicContentHeaderProperties props)

toString

public String toString()

Overrides:

toString in class Object

getClassId

public int getClassId()

getWeight

public int getWeight()

getBodySize

public long getBodySize()

unsigned long but java can't handle that anyway when allocating byte array

Returns:

the body size

setBodySize

public void setBodySize(long bodySize)

process

public static void process(MarkableDataInput buffer,
           ChannelMethodProcessor methodProcessor,
           long size)
                    throws IOException,
                           AMQFrameDecodingException

Throws:

IOException

AMQFrameDecodingException