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

Interface ClusterConnection

All Superinterfaces:

org.apache.activemq.artemis.core.server.ActiveMQComponent, org.apache.activemq.artemis.api.core.client.ClusterTopologyListener

All Known Implementing Classes:

ClusterConnectionImpl

public interface ClusterConnection
extends org.apache.activemq.artemis.core.server.ActiveMQComponent, org.apache.activemq.artemis.api.core.client.ClusterTopologyListener

Method Summary

Modifier and Type	Method and Description
void	addClusterTopologyListener(org.apache.activemq.artemis.api.core.client.ClusterTopologyListener listener)
String	describe()
void	disconnectRecord(String targetNodeID)
void	flushExecutor()
long	getCallTimeout()
org.apache.activemq.artemis.api.core.TransportConfiguration	getConnector()
org.apache.activemq.artemis.api.core.SimpleString	getName()
String	getNodeID()
Map<String,String>	getNodes() Only used for tests?
ActiveMQServer	getServer()
org.apache.activemq.artemis.core.client.impl.Topology	getTopology()
void	informClusterOfBackup()
boolean	isNodeActive(String id)
void	nodeAnnounced(long eventUID, String nodeID, String backupGroupName, String scaleDownGroupName, org.apache.activemq.artemis.api.core.Pair<org.apache.activemq.artemis.api.core.TransportConfiguration,org.apache.activemq.artemis.api.core.TransportConfiguration> connectorPair, boolean backup)
void	removeClusterTopologyListener(org.apache.activemq.artemis.api.core.client.ClusterTopologyListener listener)
void	removeRecord(String targetNodeID)
boolean	verify(String clusterUser, String clusterPassword) Verifies whether user and password match the ones configured for this ClusterConnection.

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

isStarted, start, stop

Methods inherited from interface org.apache.activemq.artemis.api.core.client.ClusterTopologyListener

nodeDown, nodeUP

Method Detail

getName

org.apache.activemq.artemis.api.core.SimpleString getName()

getNodeID

String getNodeID()

getServer

ActiveMQServer getServer()

nodeAnnounced

void nodeAnnounced(long eventUID,
                   String nodeID,
                   String backupGroupName,
                   String scaleDownGroupName,
                   org.apache.activemq.artemis.api.core.Pair<org.apache.activemq.artemis.api.core.TransportConfiguration,org.apache.activemq.artemis.api.core.TransportConfiguration> connectorPair,
                   boolean backup)

addClusterTopologyListener

void addClusterTopologyListener(org.apache.activemq.artemis.api.core.client.ClusterTopologyListener listener)

removeClusterTopologyListener

void removeClusterTopologyListener(org.apache.activemq.artemis.api.core.client.ClusterTopologyListener listener)

getNodes

Map<String,String> getNodes()

Only used for tests?

Returns:

a Map of node ID and addresses

getConnector

org.apache.activemq.artemis.api.core.TransportConfiguration getConnector()

getTopology

org.apache.activemq.artemis.core.client.impl.Topology getTopology()

flushExecutor

void flushExecutor()

describe

String describe()

informClusterOfBackup

void informClusterOfBackup()

isNodeActive

boolean isNodeActive(String id)

verify

boolean verify(String clusterUser,
               String clusterPassword)

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

Parameters:

clusterUser -

clusterPassword -

Returns:

true if username and password match, false otherwise.

removeRecord

void removeRecord(String targetNodeID)

disconnectRecord

void disconnectRecord(String targetNodeID)

getCallTimeout

long getCallTimeout()