Uses of Interface
org.apache.activemq.artemis.protocol.amqp.proton.MessageReader

Packages that use MessageReader

Package	Description
org.apache.activemq.artemis.protocol.amqp.proton	This package includes classes used on the interaction with Proton, including Context classes that will be translated through the model event.

Uses of MessageReader in org.apache.activemq.artemis.protocol.amqp.proton

Classes in org.apache.activemq.artemis.protocol.amqp.proton that implement MessageReader

Modifier and Type	Class	Description
class	AMQPLargeMessageReader	Reader of AMQPLargeMessage content which reads all bytes and completes once a non-partial delivery is read.
class	AMQPMessageReader	Reader of AMQP (non-large) messages which reads all bytes and decodes once a non-partial delivery is read.
class	AMQPTunneledCoreLargeMessageReader	Reader of tunneled large Core message that have been written as the body of an AMQP delivery with a custom message format that indicates this payload.
class	AMQPTunneledCoreMessageReader	Reader of tunneled Core message that have been written as the body of an AMQP delivery with a custom message format that indicates this payload.

Fields in org.apache.activemq.artemis.protocol.amqp.proton declared as MessageReader

Modifier and Type	Field	Description
protected MessageReader	ProtonAbstractReceiver.coreLargeMessageReader
protected MessageReader	ProtonAbstractReceiver.coreMessageReader
protected final MessageReader	ProtonAbstractReceiver.largeMessageReader
protected MessageReader	ProtonAbstractReceiver.messageReader
protected final MessageReader	ProtonAbstractReceiver.standardMessageReader

Methods in org.apache.activemq.artemis.protocol.amqp.proton that return MessageReader

Modifier and Type	Method	Description
MessageReader	AMQPMessageReader.open()
MessageReader	AMQPTunneledCoreMessageReader.open()
MessageReader	MessageReader.open()	Reset any internal state of this reader and prepares it to begin processing a new delivery.
protected MessageReader	ProtonAbstractReceiver.trySelectMessageReader(org.apache.qpid.proton.engine.Receiver receiver, org.apache.qpid.proton.engine.Delivery delivery)