Constructor and Description |
---|
ContentHeaderBody(BasicContentHeaderProperties props) |
ContentHeaderBody(BasicContentHeaderProperties props,
long bodySize) |
ContentHeaderBody(MarkableDataInput buffer,
long size) |
Modifier and Type | Method and Description |
---|---|
void |
clearEncodedForm() |
static AMQFrame |
createAMQFrame(int channelId,
BasicContentHeaderProperties properties,
long bodySize) |
static ContentHeaderBody |
createFromBuffer(MarkableDataInput buffer,
long size)
Helper method that is used currently by the persistence layer.
|
void |
dispose() |
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) |
String |
toString() |
long |
writePayload(ByteBufferSender sender) |
void |
writePayload(DataOutput buffer) |
long |
writePayload(QpidByteBuffer buf) |
public static final byte TYPE
public static final int CLASS_ID
public ContentHeaderBody(MarkableDataInput buffer, long size) throws AMQFrameDecodingException, IOException
AMQFrameDecodingException
IOException
public ContentHeaderBody(BasicContentHeaderProperties props)
public ContentHeaderBody(BasicContentHeaderProperties props, long bodySize)
public byte getFrameType()
getFrameType
in interface AMQBody
public static ContentHeaderBody createFromBuffer(MarkableDataInput buffer, long size) throws AMQFrameDecodingException, AMQProtocolVersionException, IOException
buffer
- buffer to decodesize
- size of the bodyAMQFrameDecodingException
- if there is a decoding issueAMQProtocolVersionException
- if there is a version issueIOException
- if there is an IO issuepublic int getSize()
AMQBody
public void writePayload(DataOutput buffer) throws IOException
writePayload
in interface AMQBody
IOException
public long writePayload(ByteBufferSender sender) throws IOException
writePayload
in interface AMQBody
IOException
public long writePayload(QpidByteBuffer buf) throws IOException
IOException
public void handle(int channelId, AMQVersionAwareProtocolSession session) throws QpidException
handle
in interface AMQBody
QpidException
public static AMQFrame createAMQFrame(int channelId, BasicContentHeaderProperties properties, long bodySize)
public BasicContentHeaderProperties getProperties()
public int getClassId()
public int getWeight()
public long getBodySize()
public void setBodySize(long bodySize)
public static void process(MarkableDataInput buffer, ChannelMethodProcessor methodProcessor, long size) throws IOException, AMQFrameDecodingException
IOException
AMQFrameDecodingException
public void dispose()
public void clearEncodedForm()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.