Class AMQPFederationTarget

java.lang.Object

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

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

All Implemented Interfaces:

Federation

public class AMQPFederationTarget
extends AMQPFederation

This is the receiving side of an AMQP broker federation that occurs over an inbound connection from a remote peer. The federation target only comes into existence once a remote peer connects and successfully authenticates against a control link validation address. Only one federation target is allowed per connection.

Field Summary

Fields inherited from class AMQPFederation

connected, eventDispatcher, eventProcessor, FEDERATION_INSTANCE_RECORD, linkClosedinterceptors, localAddressPolicyManagers, localQueuePolicyManagers, metrics, name, remoteAddressPolicyManagers, remoteQueuePolicyManagers, scheduler, server, session, state, wildcardConfiguration

Constructor Summary

Constructors

Constructor	Description
AMQPFederationTarget(AMQPRemoteBrokerConnection brokerConnection, String name, AMQPFederationConfiguration configuration, AMQPFederationCapabilities capabilities, AMQPSessionContext session)

Method Summary

Modifier and Type	Method	Description
AMQPFederationCapabilities	getCapabilities()	Returns the federation capabilities that is in effect following negotiation.
AMQPFederationConfiguration	getConfiguration()	Returns the federation configuration that is in effect.
AMQPConnectionContext	getConnectionContext()	Returns the session context assigned to this federation instance.
AMQPSessionContext	getSessionContext()	Returns the session context assigned to this federation instance.
protected void	handleFederationInitialized()	Provides an entry point for the concrete federation implementation to respond to being initialized.
protected void	signalError(Exception cause)	Error signaling API that must be implemented by the specific federation implementation to handle errors encountered during normal operations.
protected void	signalResourceCreateError(Exception cause)	Error signaling API that must be implemented by the specific federation implementation to handle error when creating a federation resource such as an outgoing receiver link.

Methods inherited from class AMQPFederation

addAddressMatchPolicy, addLinkClosedInterceptor, addQueueMatchPolicy, getMetrics, getName, getRemoteAddressPolicyManager, getRemoteQueuePolicyManager, getScheduler, getServer, getWildcardConfiguration, handleFederationShutdown, handleFederationStarted, handleFederationStopped, initialize, invokeLinkClosedInterceptors, isConnected, isStarted, removeLinkClosedInterceptor, shutdown, signalFederationStarted, signalFederationStopped, start, stop

Methods inherited from class Object

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

Constructor Details

AMQPFederationTarget

public AMQPFederationTarget(AMQPRemoteBrokerConnection brokerConnection,
 String name,
 AMQPFederationConfiguration configuration,
 AMQPFederationCapabilities capabilities,
 AMQPSessionContext session)

Method Details

getConnectionContext

public AMQPConnectionContext getConnectionContext()

Description copied from class: AMQPFederation

Returns the session context assigned to this federation instance.

Specified by:

getConnectionContext in class AMQPFederation

Returns:

the session context assigned to this federation instance

getCapabilities

public AMQPFederationCapabilities getCapabilities()

Description copied from class: AMQPFederation

Returns the federation capabilities that is in effect following negotiation.

Specified by:

getCapabilities in class AMQPFederation

Returns:

the federation capabilities that is in effect following negotiation

getSessionContext

public AMQPSessionContext getSessionContext()

Description copied from class: AMQPFederation

Returns the session context assigned to this federation instance.

Specified by:

getSessionContext in class AMQPFederation

Returns:

the session context assigned to this federation instance

getConfiguration

public AMQPFederationConfiguration getConfiguration()

Description copied from class: AMQPFederation

Returns the federation configuration that is in effect.

Specified by:

getConfiguration in class AMQPFederation

Returns:

the federation configuration that is in effect

handleFederationInitialized

protected void handleFederationInitialized()
                                    throws ActiveMQException

Description copied from class: AMQPFederation

Provides an entry point for the concrete federation implementation to respond to being initialized.

Overrides:

handleFederationInitialized in class AMQPFederation

Throws:

ActiveMQException - if an error is thrown during initialization handling.

signalResourceCreateError

protected void signalResourceCreateError(Exception cause)

Description copied from class: AMQPFederation

Error signaling API that must be implemented by the specific federation implementation to handle error when creating a federation resource such as an outgoing receiver link.

Specified by:

signalResourceCreateError in class AMQPFederation

Parameters:

cause - The error that caused the resource creation to fail.

signalError

protected void signalError(Exception cause)

Description copied from class: AMQPFederation

Error signaling API that must be implemented by the specific federation implementation to handle errors encountered during normal operations.

Specified by:

signalError in class AMQPFederation

Parameters:

cause - The error that caused the operation to fail.