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.Modifier and Type | Class and Description |
---|---|
static class |
ClusterManager.IncomingInterceptorLookingForExceptionMessage |
Constructor and Description |
---|
ClusterManager(ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
Configuration configuration,
NodeManager nodeManager,
boolean backup) |
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() |
public ClusterManager(ExecutorFactory executorFactory, HornetQServer server, PostOffice postOffice, ScheduledExecutorService scheduledExecutor, ManagementService managementService, Configuration configuration, NodeManager nodeManager, boolean backup)
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 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()
public void informClusterOfBackup(String name)
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.