Uses of Class
org.apache.activemq.artemis.protocol.amqp.proton.ProtonAbstractReceiver

Packages that use ProtonAbstractReceiver

Package	Description
org.apache.activemq.artemis.protocol.amqp.connect.bridge
org.apache.activemq.artemis.protocol.amqp.connect.federation
org.apache.activemq.artemis.protocol.amqp.connect.mirror
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 ProtonAbstractReceiver in org.apache.activemq.artemis.protocol.amqp.connect.bridge

Fields in org.apache.activemq.artemis.protocol.amqp.connect.bridge declared as ProtonAbstractReceiver

Modifier and Type	Field	Description
protected ProtonAbstractReceiver	AMQPBridgeReceiver.receiver

Uses of ProtonAbstractReceiver in org.apache.activemq.artemis.protocol.amqp.connect.federation

Subclasses of ProtonAbstractReceiver in org.apache.activemq.artemis.protocol.amqp.connect.federation

Modifier and Type	Class	Description
protected class	AMQPFederationAddressConsumer.AMQPFederatedAddressDeliveryHandler	Wrapper around the standard receiver context that provides federation specific entry points and customizes inbound delivery handling for this Address receiver.
class	AMQPFederationCommandProcessor	A specialized AMQP Receiver that handles commands from a remote Federation connection such as handling incoming policies that should be applied to local addresses and queues.
class	AMQPFederationEventProcessor	A specialized AMQP Receiver that handles events from a remote Federation connection such as addition of addresses or queues where federation was requested but they did not exist at the time and the federation consumer was rejected.

Fields in org.apache.activemq.artemis.protocol.amqp.connect.federation declared as ProtonAbstractReceiver

Modifier and Type	Field	Description
protected ProtonAbstractReceiver	AMQPFederationConsumer.receiver

Uses of ProtonAbstractReceiver in org.apache.activemq.artemis.protocol.amqp.connect.mirror

Subclasses of ProtonAbstractReceiver in org.apache.activemq.artemis.protocol.amqp.connect.mirror

Modifier and Type	Class	Description
class	AMQPMirrorControllerTarget

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

Subclasses of ProtonAbstractReceiver in org.apache.activemq.artemis.protocol.amqp.proton

Modifier and Type	Class	Description
class	ProtonServerReceiverContext	This is the equivalent for the ServerProducer

Fields in org.apache.activemq.artemis.protocol.amqp.proton with type parameters of type ProtonAbstractReceiver

Modifier and Type	Field	Description
protected BiConsumer<ProtonAbstractReceiver, Boolean>	ProtonAbstractReceiver.pendingStop
protected Map<org.apache.qpid.proton.engine.Receiver, ProtonAbstractReceiver>	AMQPSessionContext.receivers

Methods in org.apache.activemq.artemis.protocol.amqp.proton with type parameters of type ProtonAbstractReceiver

Modifier and Type	Method	Description
<T extends ProtonAbstractReceiver> T	AMQPSessionContext.addReceiver(org.apache.qpid.proton.engine.Receiver receiver, BiFunction<AMQPSessionContext, org.apache.qpid.proton.engine.Receiver, T> receiverBuilder)

Methods in org.apache.activemq.artemis.protocol.amqp.proton that return types with arguments of type ProtonAbstractReceiver

Modifier and Type	Method	Description
Map<org.apache.qpid.proton.engine.Receiver, ProtonAbstractReceiver>	AMQPSessionContext.getReceivers()

Methods in org.apache.activemq.artemis.protocol.amqp.proton with parameters of type ProtonAbstractReceiver

Modifier and Type	Method	Description
static Runnable	ProtonAbstractReceiver.createCreditRunnable(int refill, int threshold, org.apache.qpid.proton.engine.Receiver receiver, AMQPConnectionContext connection, ProtonAbstractReceiver context)	This Credit Runnable can be used to manage the credit replenishment of a target AMQP receiver.

Method parameters in org.apache.activemq.artemis.protocol.amqp.proton with type arguments of type ProtonAbstractReceiver

Modifier and Type	Method	Description
void	ProtonAbstractReceiver.stop(int stopTimeout, BiConsumer<ProtonAbstractReceiver, Boolean> onStopped)	Stop the receiver from granting additional credit and drains any granted credit from the link already.

Constructors in org.apache.activemq.artemis.protocol.amqp.proton with parameters of type ProtonAbstractReceiver

Modifier	Constructor	Description
	AMQPLargeMessageReader(ProtonAbstractReceiver serverReceiver)
	AMQPMessageReader(ProtonAbstractReceiver serverReceiver)
	AMQPTunneledCoreLargeMessageReader(ProtonAbstractReceiver serverReceiver)
	AMQPTunneledCoreMessageReader(ProtonAbstractReceiver serverReceiver)