org.hornetq.core.server.cluster

Class ClusterManager

java.lang.Object

org.hornetq.core.server.cluster.ClusterManager

All Implemented Interfaces:

HornetQComponent

public final class ClusterManager
extends Object
implements HornetQComponent

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.

Author:

Tim Fox, Clebert Suconic

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ClusterManager.IncomingInterceptorLookingForExceptionMessage

Constructor Summary

Constructors

Constructor and Description
ClusterManager(ExecutorFactory executorFactory, HornetQServer server, PostOffice postOffice, ScheduledExecutorService scheduledExecutor, ManagementService managementService, Configuration configuration, NodeManager nodeManager, boolean backup)

Method Summary

Modifier and Type	Method and Description
void	announceReplicatingBackupToLive(Channel liveChannel, boolean attemptingFailBack) XXX HORNETQ-720
void	clear()
void	deploy()
void	deployBridge(BridgeConfiguration config)
String	describe()
void	destroyBridge(String name)
void	flushExecutor()
Map<String,Bridge>	getBridges()
Set<BroadcastGroup>	getBroadcastGroups()
ClusterConnection	getClusterConnection(String name)
Set<ClusterConnection>	getClusterConnections()
ClusterConnection	getDefaultConnection(TransportConfiguration acceptorConfig) Return the default ClusterConnection to be used case it's not defined by the acceptor
String	getNodeGroupName()
String	getNodeId()
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

Constructor Detail

ClusterManager

public ClusterManager(ExecutorFactory executorFactory,
                      HornetQServer server,
                      PostOffice postOffice,
                      ScheduledExecutorService scheduledExecutor,
                      ManagementService managementService,
                      Configuration configuration,
                      NodeManager nodeManager,
                      boolean backup)

Method Detail

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()

getNodeGroupName

public String getNodeGroupName()

deploy

public void deploy()
            throws Exception

Throws:

Exception

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

flushExecutor

public void flushExecutor()

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

getBridges

public Map<String,Bridge> getBridges()

getClusterConnections

public Set<ClusterConnection> getClusterConnections()

getBroadcastGroups

public Set<BroadcastGroup> getBroadcastGroups()

getClusterConnection

public ClusterConnection getClusterConnection(String name)

announceReplicatingBackupToLive

public void announceReplicatingBackupToLive(Channel liveChannel,
                                            boolean attemptingFailBack)
                                     throws HornetQException

XXX HORNETQ-720

Parameters:

liveChannel - channel for opening connection with live

attemptingFailBack - if true then this server wants to trigger a fail-back when up-to-date, that is it wants to take over the role of 'live' from the current 'live' server.

Throws:

HornetQException

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)