Class AMQPFederationAddressConsumer

java.lang.Object

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

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

All Implemented Interfaces:

FederationConsumer

Direct Known Subclasses:

AMQPFederationAddressBindingsConsumer, AMQPFederationAddressConduitConsumer

public abstract class AMQPFederationAddressConsumer
extends AMQPFederationConsumer

Base AMQP federation address consumer implementation that provides the common functionality that all federation address consumers must provide with extension points to customize the actual message routing behavior as needed.

Nested Class Summary

Nested Classes

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.

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
AMQPFederationAddressConsumer(AMQPFederationAddressPolicyManager manager, AMQPFederationConsumerConfiguration configuration, AMQPSessionContext session, FederationConsumerInfo consumerInfo, AMQPFederationMetrics.ConsumerMetrics metrics)

Method Summary

Modifier and Type	Method	Description
protected abstract 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.
protected final void	doCreateReceiver()	Called during the initialization of the consumer to trigger an asynchronous link attach of the underlying AMQP receiver that backs this federation consumer.
final int	getReceiverIdleTimeout()	Returns the idle timeout value that is used applied to quiesced receivers.

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

AMQPFederationAddressConsumer

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

Method Details

getReceiverIdleTimeout

public final int getReceiverIdleTimeout()

Description copied from class: AMQPFederationConsumer

Returns the idle timeout value that is used applied to quiesced receivers.

Specified by:

getReceiverIdleTimeout in class AMQPFederationConsumer

Returns:

the idle timeout value that is used applied to quiesced receivers

doCreateReceiver

protected final void doCreateReceiver()

Description copied from class: AMQPFederationConsumer

Called during the initialization of the consumer to trigger an asynchronous link attach of the underlying AMQP receiver that backs this federation consumer. The new receiver should be initialized in a started state. This method executes on the connection thread and should not block. This method will be called from the thread of the connection this consumer operates on.

Specified by:

doCreateReceiver in class AMQPFederationConsumer

createDeliveryHandler

protected abstract 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.

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.