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

Class ClusterManager

java.lang.Object

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

All Implemented Interfaces:

ActiveMQComponent

public class ClusterManager
extends Object
implements 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(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(Channel channel, Acceptor acceptorUsed, CoreRemotingConnection remotingConnection, Activation activation)
ClusterManager	addProtocolIgnoredAddress(String ignoredAddress)
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(TransportConfiguration acceptorConfig) Return the default ClusterConnection to be used case it's not defined by the acceptor
HAManager	getHAManager()
String	getNodeId()
Collection<String>	getProtocolIgnoredAddresses()
QuorumManager	getQuorumManager()
String	getScaleDownGroupName()
void	informClusterOfBackup(String name)
boolean	isStarted()
void	removeClusterLocator(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

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

asyncStop

Constructor Detail

ClusterManager

public ClusterManager(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(Channel channel,
                                     Acceptor acceptorUsed,
                                     CoreRemotingConnection remotingConnection,
                                     Activation activation)

describe

public String describe()

getDefaultConnection

public ClusterConnection getDefaultConnection(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 ActiveMQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Throws:

Exception

flushExecutor

public void flushExecutor()

isStarted

public boolean isStarted()

Specified by:

isStarted in interface 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(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)

addProtocolIgnoredAddress

public ClusterManager addProtocolIgnoredAddress(String ignoredAddress)

getProtocolIgnoredAddresses

public Collection<String> getProtocolIgnoredAddresses()