Class AMQPBridgeFromQueueReceiver

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeReceiver

org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeFromQueueReceiver

All Implemented Interfaces:

Closeable, AutoCloseable

public class AMQPBridgeFromQueueReceiver
extends AMQPBridgeReceiver

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

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 AMQPBridgeReceiver

bridgeManager, closed, configuration, connection, DEFAULT_OUTCOME, initialized, LINK_SEQUENCE_ID, metrics, OUTCOMES, policy, policyManager, protonReceiver, receiver, receiverInfo, remoteCloseHandler, remoteOpenHandler, session, transformer

Constructor Summary

Constructors

Constructor	Description
AMQPBridgeFromQueueReceiver(AMQPBridgeFromPolicyManager policyManager, AMQPBridgeReceiverConfiguration configuration, AMQPSessionContext session, AMQPBridgeReceiverInfo receiverInfo, AMQPBridgeQueuePolicy policy, AMQPBridgeMetrics.ReceiverMetrics metrics)

Method Summary

Modifier and Type	Method	Description
protected void	doCreateReceiver()	Called during the initialization of the receiver to trigger an asynchronous link attach of the underlying AMQP receiver that backs this bridgeManager receiver.
int	getReceiverIdleTimeout()	Returns the idle timeout value that is used applied to quiesced receivers.

Methods inherited from class AMQPBridgeReceiver

close, getBridgeManager, getMessagesReceived, getPolicy, getPolicyManager, getReceiverInfo, getRemoteTerminusCapabilities, getRole, initialize, isClosed, isInitialized, recordMessageReceived, remoteLinkClosedInterceptor, setRemoteClosedHandler, setRemoteOpenHandler, 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

AMQPBridgeFromQueueReceiver

public AMQPBridgeFromQueueReceiver(AMQPBridgeFromPolicyManager policyManager,
 AMQPBridgeReceiverConfiguration configuration,
 AMQPSessionContext session,
 AMQPBridgeReceiverInfo receiverInfo,
 AMQPBridgeQueuePolicy policy,
 AMQPBridgeMetrics.ReceiverMetrics metrics)

Method Details

getReceiverIdleTimeout

public int getReceiverIdleTimeout()

Description copied from class: AMQPBridgeReceiver

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

Specified by:

getReceiverIdleTimeout in class AMQPBridgeReceiver

Returns:

the idle timeout value that is used applied to quiesced receivers

doCreateReceiver

protected void doCreateReceiver()

Description copied from class: AMQPBridgeReceiver

Called during the initialization of the receiver to trigger an asynchronous link attach of the underlying AMQP receiver that backs this bridgeManager receiver. 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 receiver operates on.

Specified by:

doCreateReceiver in class AMQPBridgeReceiver