Class AMQPFederationAddressConduitConsumer

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationConsumer

org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationAddressConsumer

org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationAddressConduitConsumer

All Implemented Interfaces:

FederationConsumer

public final class AMQPFederationAddressConduitConsumer
extends AMQPFederationAddressConsumer

Consumer implementation for Federated Addresses that receives from a remote AMQP peer and then routes the messages to the target address for dispatch to all attached bindings. The consumer serves as a conduit for message sent to the remote address passing across the federation link and then being sent to the local address to be routed to all the current bindings on that address, any messages that are not consumed by local bindings (due to filters) are discarded.

Nested Class Summary

Nested classes/interfaces inherited from class AMQPFederationAddressConsumer

AMQPFederationAddressConsumer.AMQPFederatedAddressDeliveryHandler

Field Summary

Fields inherited from class AMQPFederationConsumer

closed, configuration, connection, consumerInfo, DEFAULT_OUTCOME, federation, initialized, LINK_SEQUENCE_ID, manager, metrics, OUTCOMES, protonReceiver, receiver, remoteCloseHandler, remoteCloseInterceptor, remoteOpenHandler, session, transformer

Constructor Summary

Constructors

Constructor	Description
AMQPFederationAddressConduitConsumer(AMQPFederationAddressPolicyManager manager, AMQPFederationConsumerConfiguration configuration, AMQPSessionContext session, FederationConsumerInfo consumerInfo, AMQPFederationMetrics.ConsumerMetrics metrics)

Method Summary

Modifier and Type	Method	Description
protected AMQPFederationAddressConsumer.AMQPFederatedAddressDeliveryHandler	createDeliveryHandler(org.apache.qpid.proton.engine.Receiver receiver)	Create the delivery handler instance that will assigned as the context on the AMQP receiver link instance.

Methods inherited from class AMQPFederationAddressConsumer

doCreateReceiver, getReceiverIdleTimeout

Methods inherited from class AMQPFederationConsumer

close, getConfiguration, getConsumerInfo, getFederation, getMessagesReceived, getPolicyManager, getRole, initialize, isClosed, isInitialized, recordFederatedMessageReceived, remoteLinkClosedInterceptor, setRemoteClosedHandler, setRemoteOpenHandler, signalPluginAfterFederationConsumerMessageHandled, signalPluginBeforeFederationConsumerMessageHandled, startAsync, stopAsync

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AMQPFederationAddressConduitConsumer

public AMQPFederationAddressConduitConsumer(AMQPFederationAddressPolicyManager manager,
 AMQPFederationConsumerConfiguration configuration,
 AMQPSessionContext session,
 FederationConsumerInfo consumerInfo,
 AMQPFederationMetrics.ConsumerMetrics metrics)

Method Details

createDeliveryHandler

protected AMQPFederationAddressConsumer.AMQPFederatedAddressDeliveryHandler createDeliveryHandler(org.apache.qpid.proton.engine.Receiver receiver)

Description copied from class: AMQPFederationAddressConsumer

Create the delivery handler instance that will assigned as the context on the AMQP receiver link instance.

Specified by:

createDeliveryHandler in class AMQPFederationAddressConsumer

Parameters:

receiver - The Receiver instance that the returned delivery handler is bound to.

Returns:

a new delivery handler that will route incoming messages to their intended target.