BasicContentHeaderProperties |
ContentHeaderPropertiesFactory.createContentHeaderProperties(int classId,
int propertyFlags,
MarkableDataInput buffer,
int size) |
static ContentHeaderBody |
ContentHeaderBody.createFromBuffer(MarkableDataInput buffer,
long size)
Helper method that is used currently by the persistence layer.
|
boolean |
ProtocolInitiation.Decoder.decodable(MarkableDataInput in) |
static ChannelOpenOkBody |
ChannelOpenOkBody.getInstance(ProtocolVersion protocolVersion,
MarkableDataInput input) |
void |
BasicContentHeaderProperties.populatePropertiesFromBuffer(MarkableDataInput buffer,
int propertyFlags,
int size) |
static void |
HeartbeatBody.process(int channel,
MarkableDataInput in,
MethodProcessor processor,
long bodySize) |
static void |
ChannelOpenBody.process(int channelId,
MarkableDataInput buffer,
ServerMethodProcessor dispatcher) |
static void |
BasicNackBody.process(MarkableDataInput buffer,
ChannelMethodProcessor dispatcher) |
static void |
ChannelFlowBody.process(MarkableDataInput buffer,
ChannelMethodProcessor dispatcher) |
static void |
ChannelCloseBody.process(MarkableDataInput buffer,
ChannelMethodProcessor dispatcher) |
static void |
ChannelFlowOkBody.process(MarkableDataInput buffer,
ChannelMethodProcessor dispatcher) |
static void |
BasicAckBody.process(MarkableDataInput buffer,
ChannelMethodProcessor dispatcher) |
static void |
ContentBody.process(MarkableDataInput in,
ChannelMethodProcessor methodProcessor,
long bodySize) |
static void |
ContentHeaderBody.process(MarkableDataInput buffer,
ChannelMethodProcessor methodProcessor,
long size) |
static void |
BasicGetEmptyBody.process(MarkableDataInput buffer,
ClientChannelMethodProcessor dispatcher) |
static void |
BasicCancelOkBody.process(MarkableDataInput in,
ClientChannelMethodProcessor dispatcher) |
static void |
BasicConsumeOkBody.process(MarkableDataInput buffer,
ClientChannelMethodProcessor dispatcher) |
static void |
ChannelAlertBody.process(MarkableDataInput buffer,
ClientChannelMethodProcessor dispatcher) |
static void |
BasicGetOkBody.process(MarkableDataInput buffer,
ClientChannelMethodProcessor dispatcher) |
static void |
QueueDeleteOkBody.process(MarkableDataInput buffer,
ClientChannelMethodProcessor dispatcher) |
static void |
QueueDeclareOkBody.process(MarkableDataInput buffer,
ClientChannelMethodProcessor dispatcher) |
static void |
QueuePurgeOkBody.process(MarkableDataInput buffer,
ClientChannelMethodProcessor dispatcher) |
static void |
ExchangeBoundOkBody.process(MarkableDataInput buffer,
ClientChannelMethodProcessor dispatcher) |
static void |
BasicReturnBody.process(MarkableDataInput buffer,
ClientChannelMethodProcessor dispatcher) |
static void |
AccessRequestOkBody.process(MarkableDataInput buffer,
ClientChannelMethodProcessor dispatcher) |
static void |
BasicDeliverBody.process(MarkableDataInput buffer,
ClientChannelMethodProcessor dispatcher) |
static void |
ConnectionStartBody.process(MarkableDataInput in,
ClientMethodProcessor dispatcher) |
static void |
ConnectionOpenOkBody.process(MarkableDataInput buffer,
ClientMethodProcessor dispatcher) |
static void |
ConnectionTuneBody.process(MarkableDataInput buffer,
ClientMethodProcessor dispatcher) |
static void |
ConnectionRedirectBody.process(MarkableDataInput buffer,
ClientMethodProcessor dispatcher) |
static void |
ConnectionSecureBody.process(MarkableDataInput in,
ClientMethodProcessor dispatcher) |
static void |
ConnectionCloseBody.process(MarkableDataInput buffer,
MethodProcessor dispatcher) |
static void |
ChannelOpenOkBody.process(MarkableDataInput in,
ProtocolVersion protocolVersion,
ClientChannelMethodProcessor dispatcher) |
static void |
BasicRecoverBody.process(MarkableDataInput in,
ProtocolVersion protocolVersion,
ServerChannelMethodProcessor dispatcher) |
static void |
QueueBindBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
BasicGetBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
AccessRequestBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
ExchangeBoundBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
BasicRejectBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
ExchangeDeleteBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
QueuePurgeBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
BasicQosBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
BasicCancelBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
QueueDeleteBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
QueueDeclareBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
BasicRecoverSyncBody.process(MarkableDataInput in,
ServerChannelMethodProcessor dispatcher) |
static void |
QueueUnbindBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
BasicConsumeBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
BasicPublishBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
ConfirmSelectBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
ExchangeDeclareBody.process(MarkableDataInput buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
ConnectionOpenBody.process(MarkableDataInput buffer,
ServerMethodProcessor dispatcher) |
static void |
ConnectionTuneOkBody.process(MarkableDataInput buffer,
ServerMethodProcessor dispatcher) |
static void |
ConnectionSecureOkBody.process(MarkableDataInput in,
ServerMethodProcessor dispatcher) |
static void |
ConnectionStartOkBody.process(MarkableDataInput in,
ServerMethodProcessor dispatcher) |
int |
BasicContentHeaderProperties.read(MarkableDataInput input) |
static FieldTable |
EncodingUtils.readFieldTable(MarkableDataInput input) |
static AMQTypedValue |
AMQTypedValue.readFromBuffer(MarkableDataInput buffer) |