Class AMQPBridgeFromAddressReceiver

java.lang.Object

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

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

All Implemented Interfaces:

Closeable, AutoCloseable

public class AMQPBridgeFromAddressReceiver
extends AMQPBridgeReceiver

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

Field Summary

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
AMQPBridgeFromAddressReceiver(AMQPBridgeFromPolicyManager policyManager, AMQPBridgeReceiverConfiguration configuration, AMQPSessionContext session, AMQPBridgeReceiverInfo receiverInfo, AMQPBridgeAddressPolicy 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.
final AMQPBridgeAddressPolicy	getPolicy()	(@return the policy that this sender was configured to use)
int	getReceiverIdleTimeout()	Returns the idle timeout value that is used applied to quiesced receivers.

Methods inherited from class AMQPBridgeReceiver

close, getBridgeManager, getMessagesReceived, 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

Constructor Details

AMQPBridgeFromAddressReceiver

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

Method Details

getPolicy

public final AMQPBridgeAddressPolicy getPolicy()

Description copied from class: AMQPBridgeReceiver

(@return the policy that this sender was configured to use)

Overrides:

getPolicy in class AMQPBridgeReceiver

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