Constructor and Description |
---|
HeartbeatBody() |
HeartbeatBody(DataInputStream buffer,
long size) |
Modifier and Type | Method and Description |
---|---|
byte |
getFrameType() |
int |
getSize()
Get the size of the body
|
void |
handle(int channelId,
AMQVersionAwareProtocolSession session) |
protected void |
populateFromBuffer(DataInputStream buffer,
long size) |
static void |
process(int channel,
MarkableDataInput in,
MethodProcessor processor,
long bodySize) |
AMQFrame |
toFrame() |
long |
writePayload(ByteBufferSender sender) |
void |
writePayload(DataOutput buffer) |
public static final byte TYPE
public static final AMQFrame FRAME
public HeartbeatBody()
public HeartbeatBody(DataInputStream buffer, long size) throws IOException
IOException
public byte getFrameType()
getFrameType
in interface AMQBody
public int getSize()
AMQBody
public void writePayload(DataOutput buffer)
writePayload
in interface AMQBody
public long writePayload(ByteBufferSender sender) throws IOException
writePayload
in interface AMQBody
IOException
public void handle(int channelId, AMQVersionAwareProtocolSession session) throws QpidException
handle
in interface AMQBody
QpidException
protected void populateFromBuffer(DataInputStream buffer, long size) throws AMQFrameDecodingException, IOException
AMQFrameDecodingException
IOException
public AMQFrame toFrame()
public static void process(int channel, MarkableDataInput in, MethodProcessor processor, long bodySize) throws IOException
IOException
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.