Package org.apache.activemq.artemis.core.server.routing.pools

Class ClusterPool

java.lang.Object

org.apache.activemq.artemis.core.server.routing.pools.AbstractPool

org.apache.activemq.artemis.core.server.routing.pools.ClusterPool

All Implemented Interfaces:

ClusterTopologyListener, ActiveMQComponent, Pool

public class ClusterPool
extends AbstractPool
implements ClusterTopologyListener

Constructor Summary

Constructors

Constructor	Description
ClusterPool(TargetFactory targetFactory, ScheduledExecutorService scheduledExecutor, int checkPeriod, ClusterConnection clusterConnection)

Method Summary

Modifier and Type	Method	Description
void	nodeDown(long eventUID, String nodeID)	Triggered when a node leaves the cluster.
void	nodeUP(TopologyMember member, boolean last)	Triggered when a node joins the cluster.
void	start()
void	stop()

Methods inherited from class org.apache.activemq.artemis.core.server.routing.pools.AbstractPool

addTarget, addTarget, addTargetProbe, getAllTargets, getCheckPeriod, getPassword, getQuorumSize, getQuorumTimeout, getReadyTarget, getTarget, getTargetProbes, getTargets, getUsername, isStarted, isTargetReady, removeTarget, removeTargetProbe, setPassword, setQuorumSize, setQuorumTimeout, setUsername

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop

Constructor Detail

ClusterPool

public ClusterPool(TargetFactory targetFactory,
                   ScheduledExecutorService scheduledExecutor,
                   int checkPeriod,
                   ClusterConnection clusterConnection)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Overrides:

start in class AbstractPool

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Overrides:

stop in class AbstractPool

Throws:

Exception

nodeUP

public void nodeUP(TopologyMember member,
                   boolean last)

Description copied from interface: ClusterTopologyListener

Triggered when a node joins the cluster.

Specified by:

nodeUP in interface ClusterTopologyListener

last - if the whole cluster topology is being transmitted (after adding the listener to the cluster connection) this parameter will be true for the last topology member.

nodeDown

public void nodeDown(long eventUID,
                     String nodeID)

Description copied from interface: ClusterTopologyListener

Triggered when a node leaves the cluster.

Specified by:

nodeDown in interface ClusterTopologyListener

nodeID - the id of the node leaving the cluster