Class AMQPFederationQueueConsumer

java.lang.Object

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

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

All Implemented Interfaces:

FederationConsumer

public final class AMQPFederationQueueConsumer
extends AMQPFederationConsumer

Consumer implementation for Federated Queues that receives from a remote AMQP peer and forwards those messages onto the internal broker Queue for consumption by an attached resource.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_PENDING_MSG_CHECK_BACKOFF_MULTIPLIER
static final int	DEFAULT_PENDING_MSG_CHECK_MAX_DELAY

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

Method Summary

Modifier and Type	Method	Description
protected 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.
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

Field Details

DEFAULT_PENDING_MSG_CHECK_BACKOFF_MULTIPLIER

public static final int DEFAULT_PENDING_MSG_CHECK_BACKOFF_MULTIPLIER

See Also:

• Constant Field Values

DEFAULT_PENDING_MSG_CHECK_MAX_DELAY

public static final int DEFAULT_PENDING_MSG_CHECK_MAX_DELAY

See Also:

• Constant Field Values

Constructor Details

AMQPFederationQueueConsumer

public AMQPFederationQueueConsumer(AMQPFederationQueuePolicyManager manager,
 AMQPFederationConsumerConfiguration configuration,
 AMQPSessionContext session,
 FederationConsumerInfo consumerInfo,
 AMQPFederationMetrics.ConsumerMetrics metrics)

Method Details

getReceiverIdleTimeout

public 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 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