Package org.apache.activemq.artemis.core.server.federation

Class FederationDownstream

java.lang.Object

org.apache.activemq.artemis.core.server.federation.AbstractFederationStream

org.apache.activemq.artemis.core.server.federation.FederationDownstream

All Implemented Interfaces:

SessionFailureListener, FailureListener, FederationStream

public class FederationDownstream
extends AbstractFederationStream
implements SessionFailureListener

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FEDERATION_DOWNSTREAM_NAME

Fields inherited from class org.apache.activemq.artemis.core.server.federation.AbstractFederationStream

connection, federatedAddressMap, federatedQueueMap, federation, name, server

Constructor Summary

Constructors

Constructor	Description
FederationDownstream(ActiveMQServer server, Federation federation, String name, FederationDownstreamConfiguration config, FederationConnection connection)

Method Summary

Modifier and Type	Method	Description
void	beforeReconnect(ActiveMQException exception)	Notifies that a connection has failed due to the specified exception.
void	connectionFailed(ActiveMQException exception, boolean failedOver)	Notifies that a connection has failed due to the specified exception.
void	connectionFailed(ActiveMQException exception, boolean failedOver, String scaleDownTargetNodeID)	Notifies that a connection has failed due to the specified exception.
void	deploy(FederationConfiguration federationConfiguration)
void	start()
void	stop()
void	undeploy()

Methods inherited from class org.apache.activemq.artemis.core.server.federation.AbstractFederationStream

callFederationStreamStartedPlugins, callFederationStreamStoppedPlugins, getConfig, getConnection, getFederation, getName, getPassword, getPriorityAdjustment, getUser

Methods inherited from class java.lang.Object

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

Field Details

FEDERATION_DOWNSTREAM_NAME

public static final String FEDERATION_DOWNSTREAM_NAME

See Also:

• Constant Field Values

Constructor Details

FederationDownstream

public FederationDownstream(ActiveMQServer server,
 Federation federation,
 String name,
 FederationDownstreamConfiguration config,
 FederationConnection connection)

Method Details

start

public void start()

Specified by:

start in interface FederationStream

Overrides:

start in class AbstractFederationStream

stop

public void stop()

Specified by:

stop in interface FederationStream

Overrides:

stop in class AbstractFederationStream

deploy

public void deploy(FederationConfiguration federationConfiguration)
            throws ActiveMQException

Throws:

ActiveMQException

undeploy

public void undeploy()

connectionFailed

public void connectionFailed(ActiveMQException exception,
 boolean failedOver)

Description copied from interface: FailureListener

Notifies that a connection has failed due to the specified exception.

Specified by:

connectionFailed in interface FailureListener

Parameters:

exception - exception which has caused the connection to fail

connectionFailed

public void connectionFailed(ActiveMQException exception,
 boolean failedOver,
 String scaleDownTargetNodeID)

Description copied from interface: FailureListener

Notifies that a connection has failed due to the specified exception.

Specified by:

connectionFailed in interface FailureListener

Parameters:

exception - exception which has caused the connection to fail

scaleDownTargetNodeID - the ID of the node to which messages are scaling down

beforeReconnect

public void beforeReconnect(ActiveMQException exception)

Description copied from interface: SessionFailureListener

Notifies that a connection has failed due to the specified exception.

This method is called before the session attempts to reconnect/failover.

Specified by:

beforeReconnect in interface SessionFailureListener

Parameters:

exception - exception which has caused the connection to fail