| Package | Description |
|---|---|
| org.apache.qpid.server.protocol.v0_8 | |
| org.apache.qpid.server.protocol.v0_8.transport |
| Modifier and Type | Method and Description |
|---|---|
protected AMQFrameDecodingException |
AMQDecoder.newUnknownMethodException(int classId,
int methodId,
ProtocolVersion protocolVersion) |
| Modifier and Type | Method and Description |
|---|---|
protected int |
AMQDecoder.decodable(QpidByteBuffer in) |
protected int |
AMQDecoder.decode(QpidByteBuffer buf) |
void |
ServerDecoder.decodeBuffer(QpidByteBuffer buf) |
protected int |
BrokerDecoder.processAMQPFrames(QpidByteBuffer buf) |
protected int |
AMQDecoder.processAMQPFrames(QpidByteBuffer buf) |
protected void |
BrokerDecoder.processFrame(int channelId,
byte type,
long bodySize,
QpidByteBuffer in) |
protected void |
AMQDecoder.processFrame(int channel,
byte type,
long bodySize,
QpidByteBuffer in) |
protected void |
AMQDecoder.processInput(QpidByteBuffer in) |
protected void |
ServerDecoder.processMethod(int channelId,
QpidByteBuffer in) |
protected abstract void |
AMQDecoder.processMethod(int channelId,
QpidByteBuffer in) |
static long |
EncodingUtils.readLongAsShortString(QpidByteBuffer buffer) |
| Modifier and Type | Method and Description |
|---|---|
BasicContentHeaderProperties |
ContentHeaderPropertiesFactory.createContentHeaderProperties(int classId,
int propertyFlags,
QpidByteBuffer buffer,
int size) |
static ContentHeaderBody |
ContentHeaderBody.createFromBuffer(QpidByteBuffer buffer,
long size)
Helper method that is used currently by the persistence layer.
|
protected void |
HeartbeatBody.populateFromBuffer(DataInputStream buffer,
long size) |
static void |
ContentHeaderBody.process(QpidByteBuffer buffer,
ChannelMethodProcessor methodProcessor,
long size) |
static void |
ChannelAlertBody.process(QpidByteBuffer buffer,
ClientChannelMethodProcessor dispatcher) |
static void |
ConnectionStartBody.process(QpidByteBuffer in,
ClientMethodProcessor dispatcher) |
static void |
ConnectionSecureBody.process(QpidByteBuffer in,
ClientMethodProcessor dispatcher) |
static void |
QueueUnbindBody.process(QpidByteBuffer buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
QueueDeclareBody.process(QpidByteBuffer buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
QueueBindBody.process(QpidByteBuffer buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
ExchangeDeclareBody.process(QpidByteBuffer buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
BasicConsumeBody.process(QpidByteBuffer buffer,
ServerChannelMethodProcessor dispatcher) |
static void |
ConnectionStartOkBody.process(QpidByteBuffer in,
ServerMethodProcessor dispatcher) |
| Constructor and Description |
|---|
BasicContentHeaderProperties(QpidByteBuffer buffer,
int propertyFlags,
int size) |
ContentHeaderBody(QpidByteBuffer buffer,
long size) |
Copyright © 2006–2021 The Apache Software Foundation. All rights reserved.