public class FrameEnd extends AmqpAbstractFrame
| Modifier and Type | Field and Description |
|---|---|
static int |
CODE |
E_ARRAY_1, E_ARRAY_4, E_BIN_1, E_BIN_4, E_BOOLEAN_1, E_BYTE_1, E_CHAR, E_DECIMAL_16, E_DECIMAL_4, E_DECIMAL_8, E_DESCRIPTOR, E_DOUBLE, E_FALSE, E_FLOAT, E_I0, E_INT_1, E_INT_4, E_L0, E_LIST_0, E_LIST_1, E_LIST_4, E_LONG_1, E_LONG_8, E_MAP_1, E_MAP_4, E_NULL, E_SHORT, E_SYMBOL_1, E_SYMBOL_4, E_TIMESTAMP, E_TRUE, E_UBYTE_1, E_UINT_1, E_UINT_4, E_ULONG_1, E_ULONG_8, E_USHORT, E_UTF8_1, E_UTF8_4, E_UUID, FT_CONN_CLOSE, FT_CONN_OPEN, FT_ERROR, FT_LINK_ATTACH, FT_LINK_DETACH, FT_LINK_FLOW, FT_MESSAGE_DISPOSITION, FT_MESSAGE_TRANSFER, FT_SESSION_END, FT_SESSION_OPEN, MIN_MAX_FRAME_SIZE, ST_MESSAGE_ACCEPTED, ST_MESSAGE_ANN, ST_MESSAGE_APP_PROPERTIES, ST_MESSAGE_DATA, ST_MESSAGE_DELIVERY_ANN, ST_MESSAGE_FOOTER, ST_MESSAGE_HEADER, ST_MESSAGE_MODIFIED, ST_MESSAGE_PROPERTIES, ST_MESSAGE_RECEIVED, ST_MESSAGE_REJECTED, ST_MESSAGE_RELEASED, ST_MESSAGE_SEQUENCE, ST_MESSAGE_SOURCE, ST_MESSAGE_TARGET, ST_MESSAGE_VALUE, ST_NODE_DELETE_ON_CLOSE, ST_NODE_DELETE_ON_NO_LINK, ST_NODE_DELETE_ON_NO_LINK_OR_MESSAGES, ST_NODE_DELETE_ON_NO_MESSAGES, ST_SASL_CHALLENGE, ST_SASL_INIT, ST_SASL_MECHANISMS, ST_SASL_OUTCOME, ST_SASL_RESPONSE, ST_XA_COORDINATOR, ST_XA_DECLARE, ST_XA_DECLARED, ST_XA_DISCHARGE, ST_XA_STATE| Constructor and Description |
|---|
FrameEnd() |
| Modifier and Type | Method and Description |
|---|---|
FrameEnd |
createInstance() |
long |
getDescriptorCode() |
AmqpError |
getError() |
void |
invoke(AmqpReader ain,
AmqpFrameHandler receiver) |
void |
readBody(AmqpReader in,
int count) |
int |
writeBody(AmqpWriter out) |
read, readValue, writepublic static final int CODE
public AmqpError getError()
public long getDescriptorCode()
getDescriptorCode in class AmqpAbstractCompositepublic FrameEnd createInstance()
createInstance in class AmqpAbstractPacketpublic void invoke(AmqpReader ain, AmqpFrameHandler receiver) throws java.io.IOException
invoke in class AmqpAbstractFramejava.io.IOExceptionpublic void readBody(AmqpReader in, int count) throws java.io.IOException
readBody in class AmqpAbstractCompositejava.io.IOExceptionpublic int writeBody(AmqpWriter out) throws java.io.IOException
writeBody in class AmqpAbstractCompositejava.io.IOException