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

Class ClusterConnectionImpl

java.lang.Object

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

All Implemented Interfaces:

ClusterTopologyListener, AfterConnectInternalListener, TopologyManager, DiscoveryListener, ActiveMQComponent, ClusterConnection

public final class ClusterConnectionImpl
extends Object
implements ClusterConnection, AfterConnectInternalListener, TopologyManager, DiscoveryListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	ClusterConnectionImpl.TopologyScanner

Constructor Summary

Constructors

Constructor	Description
ClusterConnectionImpl(ClusterManager manager, DiscoveryGroupConfiguration dg, TransportConfiguration connector, SimpleString name, SimpleString address, int minLargeMessageSize, long clientFailureCheckPeriod, long connectionTTL, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int initialConnectAttempts, int reconnectAttempts, long callTimeout, long callFailoverTimeout, boolean useDuplicateDetection, MessageLoadBalancingType messageLoadBalancingType, int confirmationWindowSize, int producerWindowSize, ExecutorFactory executorFactory, ActiveMQServer server, PostOffice postOffice, ManagementService managementService, ScheduledExecutorService scheduledExecutor, int maxHops, NodeManager nodeManager, String clusterUser, String clusterPassword, boolean allowDirectConnectionsOnly, long clusterNotificationInterval, int clusterNotificationAttempts, String clientId, int topologyScannerAttempts)
ClusterConnectionImpl(ClusterManager manager, TransportConfiguration[] staticTranspConfigs, TransportConfiguration connector, SimpleString name, SimpleString address, int minLargeMessageSize, long clientFailureCheckPeriod, long connectionTTL, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int initialConnectAttempts, int reconnectAttempts, long callTimeout, long callFailoverTimeout, boolean useDuplicateDetection, MessageLoadBalancingType messageLoadBalancingType, int confirmationWindowSize, int producerWindowSize, ExecutorFactory executorFactory, ActiveMQServer server, PostOffice postOffice, ManagementService managementService, ScheduledExecutorService scheduledExecutor, int maxHops, NodeManager nodeManager, String clusterUser, String clusterPassword, boolean allowDirectConnectionsOnly, long clusterNotificationInterval, int clusterNotificationAttempts, String clientId, int topologyScannerAttempts)

Method Summary

Modifier and Type	Method	Description
void	addClusterTopologyListener(ClusterTopologyListener listener)
void	connectorsChanged(List<DiscoveryEntry> newConnectors)
String	describe()
void	disconnectRecord(String targetNodeID)
void	flushExecutor()
BridgeMetrics	getBridgeMetrics(String nodeId)	Returns the BridgeMetrics for the bridge to the given node if exists.
Bridge[]	getBridges()
long	getCallTimeout()
TransportConfiguration	getConnector()
ClusterConnectionMetrics	getMetrics()	The metric for this cluster connection
SimpleString	getName()
String	getNodeID()
Map<String,String>	getNodes()	Only used for tests?
long	getProducerWindowSize()
Map<String,MessageFlowRecord>	getRecords()
ActiveMQServer	getServer()
ServerLocatorInternal	getServerLocator()	For tests only
SimpleString	getSfQueueName(String nodeID)
Topology	getTopology()
ClusterConnectionImpl.TopologyScanner	getTopologyScanner()
void	informClusterOfBackup()
boolean	isNodeActive(String nodeId)
boolean	isSplitBrainDetection()
boolean	isStarted()
void	nodeAnnounced(long uniqueEventID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean backup)
void	nodeDown(long eventUID, String nodeID)	Triggered when a node leaves the cluster.
void	nodeUP(TopologyMember topologyMember, boolean last)	Triggered when a node joins the cluster.
void	onConnection(ClientSessionFactoryInternal sf)
void	removeClusterTopologyListener(ClusterTopologyListener listener)
boolean	removeMember(long uniqueEventID, String nodeId, boolean disconnect)	From topologyManager
void	removeRecord(String targetNodeID)
void	setSplitBrainDetection(boolean splitBrainDetection)	This is needed on replication, however we don't need it on shared storage.
void	start()
void	stop()
String	toString()
boolean	updateMember(long uniqueEventID, String nodeId, TopologyMemberImpl memberInput)	This is the implementation of TopologyManager.
boolean	verify(String clusterUser0, String clusterPassword0)	Verifies whether user and password match the ones configured for this ClusterConnection.

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 Details

ClusterConnectionImpl

public ClusterConnectionImpl(ClusterManager manager,
 TransportConfiguration[] staticTranspConfigs,
 TransportConfiguration connector,
 SimpleString name,
 SimpleString address,
 int minLargeMessageSize,
 long clientFailureCheckPeriod,
 long connectionTTL,
 long retryInterval,
 double retryIntervalMultiplier,
 long maxRetryInterval,
 int initialConnectAttempts,
 int reconnectAttempts,
 long callTimeout,
 long callFailoverTimeout,
 boolean useDuplicateDetection,
 MessageLoadBalancingType messageLoadBalancingType,
 int confirmationWindowSize,
 int producerWindowSize,
 ExecutorFactory executorFactory,
 ActiveMQServer server,
 PostOffice postOffice,
 ManagementService managementService,
 ScheduledExecutorService scheduledExecutor,
 int maxHops,
 NodeManager nodeManager,
 String clusterUser,
 String clusterPassword,
 boolean allowDirectConnectionsOnly,
 long clusterNotificationInterval,
 int clusterNotificationAttempts,
 String clientId,
 int topologyScannerAttempts)
                      throws Exception

Throws:

Exception

ClusterConnectionImpl

public ClusterConnectionImpl(ClusterManager manager,
 DiscoveryGroupConfiguration dg,
 TransportConfiguration connector,
 SimpleString name,
 SimpleString address,
 int minLargeMessageSize,
 long clientFailureCheckPeriod,
 long connectionTTL,
 long retryInterval,
 double retryIntervalMultiplier,
 long maxRetryInterval,
 int initialConnectAttempts,
 int reconnectAttempts,
 long callTimeout,
 long callFailoverTimeout,
 boolean useDuplicateDetection,
 MessageLoadBalancingType messageLoadBalancingType,
 int confirmationWindowSize,
 int producerWindowSize,
 ExecutorFactory executorFactory,
 ActiveMQServer server,
 PostOffice postOffice,
 ManagementService managementService,
 ScheduledExecutorService scheduledExecutor,
 int maxHops,
 NodeManager nodeManager,
 String clusterUser,
 String clusterPassword,
 boolean allowDirectConnectionsOnly,
 long clusterNotificationInterval,
 int clusterNotificationAttempts,
 String clientId,
 int topologyScannerAttempts)
                      throws Exception

Throws:

Exception

Method Details

getServerLocator

public ServerLocatorInternal getServerLocator()

For tests only

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

flushExecutor

public void flushExecutor()

Specified by:

flushExecutor in interface ClusterConnection

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Throws:

Exception

addClusterTopologyListener

public void addClusterTopologyListener(ClusterTopologyListener listener)

Specified by:

addClusterTopologyListener in interface ClusterConnection

removeClusterTopologyListener

public void removeClusterTopologyListener(ClusterTopologyListener listener)

Specified by:

removeClusterTopologyListener in interface ClusterConnection

getTopology

public Topology getTopology()

Specified by:

getTopology in interface ClusterConnection

nodeAnnounced

public void nodeAnnounced(long uniqueEventID,
 String nodeID,
 String backupGroupName,
 String scaleDownGroupName,
 Pair<TransportConfiguration,TransportConfiguration> connectorPair,
 boolean backup)

Specified by:

nodeAnnounced in interface ClusterConnection

updateMember

public boolean updateMember(long uniqueEventID,
 String nodeId,
 TopologyMemberImpl memberInput)

This is the implementation of TopologyManager. It is used to reject eventual updates from a split brain server.

Specified by:

updateMember in interface TopologyManager

removeMember

public boolean removeMember(long uniqueEventID,
 String nodeId,
 boolean disconnect)

From topologyManager

Specified by:

removeMember in interface TopologyManager

setSplitBrainDetection

public void setSplitBrainDetection(boolean splitBrainDetection)

Description copied from interface: ClusterConnection

This is needed on replication, however we don't need it on shared storage.

Specified by:

setSplitBrainDetection in interface ClusterConnection

isSplitBrainDetection

public boolean isSplitBrainDetection()

Specified by:

isSplitBrainDetection in interface ClusterConnection

onConnection

public void onConnection(ClientSessionFactoryInternal sf)

Specified by:

onConnection in interface AfterConnectInternalListener

connectorsChanged

public void connectorsChanged(List<DiscoveryEntry> newConnectors)

Specified by:

connectorsChanged in interface DiscoveryListener

getTopologyScanner

public ClusterConnectionImpl.TopologyScanner getTopologyScanner()

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ActiveMQComponent

getName

public SimpleString getName()

Specified by:

getName in interface ClusterConnection

getNodeID

public String getNodeID()

Specified by:

getNodeID in interface ClusterConnection

getServer

public ActiveMQServer getServer()

Specified by:

getServer in interface ClusterConnection

isNodeActive

public boolean isNodeActive(String nodeId)

Specified by:

isNodeActive in interface ClusterConnection

getCallTimeout

public long getCallTimeout()

Specified by:

getCallTimeout in interface ClusterConnection

getProducerWindowSize

public long getProducerWindowSize()

Specified by:

getProducerWindowSize in interface ClusterConnection

getBridges

public Bridge[] getBridges()

Specified by:

getBridges in interface ClusterConnection

getNodes

public Map<String,String> getNodes()

Description copied from interface: ClusterConnection

Only used for tests?

Specified by:

getNodes in interface ClusterConnection

Returns:

a Map of node ID and addresses

getConnector

public TransportConfiguration getConnector()

Specified by:

getConnector in interface ClusterConnection

nodeDown

public void nodeDown(long eventUID,
 String nodeID)

Description copied from interface: ClusterTopologyListener

Triggered when a node leaves the cluster.

Specified by:

nodeDown in interface ClusterTopologyListener

nodeID - the id of the node leaving the cluster

nodeUP

public void nodeUP(TopologyMember topologyMember,
 boolean last)

Description copied from interface: ClusterTopologyListener

Triggered when a node joins the cluster.

Specified by:

nodeUP in interface ClusterTopologyListener

last - if the whole cluster topology is being transmitted (after adding the listener to the cluster connection) this parameter will be true for the last topology member.

getSfQueueName

public SimpleString getSfQueueName(String nodeID)

informClusterOfBackup

public void informClusterOfBackup()

Specified by:

informClusterOfBackup in interface ClusterConnection

getMetrics

public ClusterConnectionMetrics getMetrics()

Description copied from interface: ClusterConnection

The metric for this cluster connection

Specified by:

getMetrics in interface ClusterConnection

getBridgeMetrics

public BridgeMetrics getBridgeMetrics(String nodeId)

Description copied from interface: ClusterConnection

Returns the BridgeMetrics for the bridge to the given node if exists.

Specified by:

getBridgeMetrics in interface ClusterConnection

Returns:

the BridgeMetrics for the bridge to the given node if exists

getRecords

public Map<String,MessageFlowRecord> getRecords()

toString

public String toString()

Overrides:

toString in class Object

describe

public String describe()

Specified by:

describe in interface ClusterConnection

verify

public boolean verify(String clusterUser0,
 String clusterPassword0)

Description copied from interface: ClusterConnection

Verifies whether user and password match the ones configured for this ClusterConnection.

Specified by:

verify in interface ClusterConnection

Returns:

true if username and password match, false otherwise

removeRecord

public void removeRecord(String targetNodeID)

Specified by:

removeRecord in interface ClusterConnection

disconnectRecord

public void disconnectRecord(String targetNodeID)

Specified by:

disconnectRecord in interface ClusterConnection