public final class ClusterManager extends Object implements HornetQComponent
ClusterConnection
s, BroadcastGroup
s and Bridge
s.
Note that ClusterConnectionBridge
s extend Bridges but are controlled over through
ClusterConnectionImpl
. As a node is discovered a new ClusterConnectionBridge
is
deployed.
Constructor and Description |
---|
ClusterManager(ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
Configuration configuration,
NodeManager nodeManager,
boolean backup,
ExecutorService threadPool) |
Modifier and Type | Method and Description |
---|---|
void |
activate()
Activates several cluster services.
|
void |
announceBackup() |
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() |
boolean |
isStarted() |
void |
removeClusterLocator(ServerLocatorInternal serverLocator) |
void |
start() |
void |
stop() |
String |
toString() |
public ClusterManager(ExecutorFactory executorFactory, HornetQServer server, PostOffice postOffice, ScheduledExecutorService scheduledExecutor, ManagementService managementService, Configuration configuration, NodeManager nodeManager, boolean backup, ExecutorService threadPool)
public String describe()
public ClusterConnection getDefaultConnection(TransportConfiguration acceptorConfig)
public String getNodeId()
public String getNodeGroupName()
public void start() throws Exception
start
in interface HornetQComponent
Exception
public void stop() throws Exception
stop
in interface HornetQComponent
Exception
public void flushExecutor()
public boolean isStarted()
isStarted
in interface HornetQComponent
public Set<ClusterConnection> getClusterConnections()
public Set<BroadcastGroup> getBroadcastGroups()
public ClusterConnection getClusterConnection(String name)
public void activate() throws Exception
Exception
public void announceBackup()
public void announceReplicatingBackupToLive(Channel liveChannel, boolean attemptingFailBack) throws HornetQException
liveChannel
- channel for opening connection with liveattemptingFailBack
- 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.HornetQException
public void removeClusterLocator(ServerLocatorInternal serverLocator)
public void deployBridge(BridgeConfiguration config) throws Exception
Exception
public void clear()
Copyright © 2013 JBoss by Red Hat. All Rights Reserved.