| 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) |
AMQFrame |
toFrame() |
void |
writePayload(DataOutput buffer) |
public static final byte TYPE
public static final AMQFrame FRAME
public HeartbeatBody()
public HeartbeatBody(DataInputStream buffer, long size) throws IOException
IOExceptionpublic byte getFrameType()
getFrameType in interface AMQBodypublic int getSize()
AMQBodypublic void writePayload(DataOutput buffer)
writePayload in interface AMQBodypublic void handle(int channelId,
AMQVersionAwareProtocolSession session)
throws AMQException
handle in interface AMQBodyAMQExceptionprotected void populateFromBuffer(DataInputStream buffer, long size) throws AMQFrameDecodingException, IOException
AMQFrameDecodingExceptionIOExceptionpublic AMQFrame toFrame()
Copyright © 2006–2014 The Apache Software Foundation. All rights reserved.