org.hornetq.core.server.cluster.impl

Class ClusterManagerImpl

java.lang.Object

org.hornetq.core.server.cluster.impl.ClusterManagerImpl

All Implemented Interfaces:

ClusterManager, ClusterManagerInternal, HornetQComponent

public class ClusterManagerImpl
extends Object
implements ClusterManagerInternal

A ClusterManagerImpl

Author:

Tim Fox, Clebert Suconic Created 18 Nov 2008 09:23:49

Constructor Summary

Constructors

Constructor and Description
ClusterManagerImpl(ExecutorFactory executorFactory, HornetQServer server, PostOffice postOffice, ScheduledExecutorService scheduledExecutor, ManagementService managementService, Configuration configuration, UUID nodeUUID, boolean backup, boolean clustered)

Method Summary

Methods

Modifier and Type	Method and Description
void	activate()
void	addClusterLocator(ServerLocatorInternal serverLocator)
void	announceBackup()
void	clear()
void	deploy()
void	deployBridge(BridgeConfiguration config, boolean start)
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	getNodeId()
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

ClusterManagerImpl

public ClusterManagerImpl(ExecutorFactory executorFactory,
                  HornetQServer server,
                  PostOffice postOffice,
                  ScheduledExecutorService scheduledExecutor,
                  ManagementService managementService,
                  Configuration configuration,
                  UUID nodeUUID,
                  boolean backup,
                  boolean clustered)

Method Detail

describe

public String describe()

Specified by:

describe in interface ClusterManager

Returns:

getDefaultConnection

public ClusterConnection getDefaultConnection(TransportConfiguration acceptorConfig)

Description copied from interface: ClusterManager

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

Specified by:

getDefaultConnection in interface ClusterManager

Returns:

toString

public String toString()

Overrides:

toString in class Object

getNodeId

public String getNodeId()

Specified by:

getNodeId in interface ClusterManagerInternal

deploy

public void deploy()
            throws Exception

Specified by:

deploy in interface ClusterManager

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

Specified by:

flushExecutor in interface ClusterManager

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

getBridges

public Map<String,Bridge> getBridges()

Specified by:

getBridges in interface ClusterManager

getClusterConnections

public Set<ClusterConnection> getClusterConnections()

Specified by:

getClusterConnections in interface ClusterManager

getBroadcastGroups

public Set<BroadcastGroup> getBroadcastGroups()

Specified by:

getBroadcastGroups in interface ClusterManager

getClusterConnection

public ClusterConnection getClusterConnection(String name)

Specified by:

getClusterConnection in interface ClusterManager

activate

public void activate()

Specified by:

activate in interface ClusterManager

announceBackup

public void announceBackup()
                    throws Exception

Specified by:

announceBackup in interface ClusterManager

Throws:

Exception

addClusterLocator

public void addClusterLocator(ServerLocatorInternal serverLocator)

Specified by:

addClusterLocator in interface ClusterManagerInternal

removeClusterLocator

public void removeClusterLocator(ServerLocatorInternal serverLocator)

Specified by:

removeClusterLocator in interface ClusterManagerInternal

deployBridge

public void deployBridge(BridgeConfiguration config,
                boolean start)
                  throws Exception

Specified by:

deployBridge in interface ClusterManager

Throws:

Exception

destroyBridge

public void destroyBridge(String name)
                   throws Exception

Specified by:

destroyBridge in interface ClusterManager

Throws:

Exception

clear

public void clear()