org.apache.activemq.artemis.core.server.cluster

Class ClusterManager

java.lang.Object

org.apache.activemq.artemis.core.server.cluster.ClusterManager

All Implemented Interfaces:

org.apache.activemq.artemis.core.server.ActiveMQComponent

public final class ClusterManager
extends Object
implements org.apache.activemq.artemis.core.server.ActiveMQComponent

A ClusterManager manages ClusterConnections, BroadcastGroups and Bridges.

Note that ClusterConnectionBridges extend Bridges but are controlled over through ClusterConnectionImpl. As a node is discovered a new ClusterConnectionBridge is deployed.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ClusterManager.IncomingInterceptorLookingForExceptionMessage

Constructor Summary

Constructors

Constructor and Description
ClusterManager(org.apache.activemq.artemis.utils.ExecutorFactory executorFactory, ActiveMQServer server, PostOffice postOffice, ScheduledExecutorService scheduledExecutor, ManagementService managementService, Configuration configuration, NodeManager nodeManager, boolean backup)

Method Summary

Modifier and Type	Method and Description
void	addClusterChannelHandler(org.apache.activemq.artemis.core.protocol.core.Channel channel, Acceptor acceptorUsed, org.apache.activemq.artemis.core.protocol.core.CoreRemotingConnection remotingConnection, Activation activation)
void	clear()
void	deploy()
void	deployBridge(BridgeConfiguration config)
String	describe()
void	destroyBridge(String name)
void	flushExecutor()
String	getBackupGroupName()
Map<String,Bridge>	getBridges()
Set<BroadcastGroup>	getBroadcastGroups()
ClusterConnection	getClusterConnection(String name)
Set<ClusterConnection>	getClusterConnections()
ClusterController	getClusterController()
ClusterConnection	getDefaultConnection(org.apache.activemq.artemis.api.core.TransportConfiguration acceptorConfig) Return the default ClusterConnection to be used case it's not defined by the acceptor
HAManager	getHAManager()
String	getNodeId()
QuorumManager	getQuorumManager()
String	getScaleDownGroupName()
void	informClusterOfBackup(String name)
boolean	isStarted()
void	removeClusterLocator(org.apache.activemq.artemis.core.client.impl.ServerLocatorInternal serverLocator)
void	start()
void	stop()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterManager

public ClusterManager(org.apache.activemq.artemis.utils.ExecutorFactory executorFactory,
                      ActiveMQServer server,
                      PostOffice postOffice,
                      ScheduledExecutorService scheduledExecutor,
                      ManagementService managementService,
                      Configuration configuration,
                      NodeManager nodeManager,
                      boolean backup)

Method Detail

getQuorumManager

public QuorumManager getQuorumManager()

getClusterController

public ClusterController getClusterController()

getHAManager

public HAManager getHAManager()

addClusterChannelHandler

public void addClusterChannelHandler(org.apache.activemq.artemis.core.protocol.core.Channel channel,
                                     Acceptor acceptorUsed,
                                     org.apache.activemq.artemis.core.protocol.core.CoreRemotingConnection remotingConnection,
                                     Activation activation)

describe

public String describe()

getDefaultConnection

public ClusterConnection getDefaultConnection(org.apache.activemq.artemis.api.core.TransportConfiguration acceptorConfig)

Return the default ClusterConnection to be used case it's not defined by the acceptor

Returns:

default connection

toString

public String toString()

Overrides:

toString in class Object

getNodeId

public String getNodeId()

getBackupGroupName

public String getBackupGroupName()

getScaleDownGroupName

public String getScaleDownGroupName()

deploy

public void deploy()
            throws Exception

Throws:

Exception

start

public void start()
           throws Exception

Specified by:

start in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

Throws:

Exception

flushExecutor

public void flushExecutor()

isStarted

public boolean isStarted()

Specified by:

isStarted in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

getBridges

public Map<String,Bridge> getBridges()

getClusterConnections

public Set<ClusterConnection> getClusterConnections()

getBroadcastGroups

public Set<BroadcastGroup> getBroadcastGroups()

getClusterConnection

public ClusterConnection getClusterConnection(String name)

removeClusterLocator

public void removeClusterLocator(org.apache.activemq.artemis.core.client.impl.ServerLocatorInternal serverLocator)

deployBridge

public void deployBridge(BridgeConfiguration config)
                  throws Exception

Throws:

Exception

destroyBridge

public void destroyBridge(String name)
                   throws Exception

Throws:

Exception

clear

public void clear()

informClusterOfBackup

public void informClusterOfBackup(String name)