Package org.apache.activemq.artemis.core.client.impl

Interface ServerLocatorInternal

All Superinterfaces:

AutoCloseable, ServerLocator

All Known Implementing Classes:

ServerLocatorImpl

public interface ServerLocatorInternal
extends ServerLocator

Method Summary

Modifier and Type	Method	Description
void	cleanup()
ClientSessionFactoryInternal	connect()
ClientSessionFactoryInternal	connectNoWarnings()	Like connect() but it does not log warnings if it fails to connect.
void	factoryClosed(ClientSessionFactory factory)
AfterConnectInternalListener	getAfterConnectInternalListener()
TransportConfiguration	getClusterTransportConfiguration()
int	getConnectorsSize()
long	getNextRetryInterval(long retryInterval, double retryIntervalMultiplier, long maxRetryInterval)
String	getNodeID()
Topology	getTopology()	Exposes the Topology used by this ServerLocator.
boolean	isClusterConnection()
boolean	isConnectable()
ClientProtocolManager	newProtocolManager()
default void	notifyNodeDown(long uniqueEventID, String nodeID)	Notify this about a node down event.
void	notifyNodeDown(long uniqueEventID, String nodeID, boolean disconnect)
void	notifyNodeUp(long uniqueEventID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean last)
void	resetToInitialConnectors()
Pair<TransportConfiguration,TransportConfiguration>	selectNextConnectorPair()
ServerLocatorInternal	setAfterConnectionInternalListener(AfterConnectInternalListener listener)
ServerLocatorInternal	setClusterConnection(boolean clusterConnection)
ServerLocatorInternal	setClusterTransportConfiguration(TransportConfiguration tc)
ServerLocatorInternal	setDiscoveryListener(DiscoveryListener listener)
ServerLocatorInternal	setIdentity(String identity)	Used to better identify Cluster Connection Locators on logs.
ServerLocatorInternal	setNodeID(String nodeID)
void	start(Executor executor)

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

addClusterTopologyListener, addIncomingInterceptor, addOutgoingInterceptor, allInVM, close, createSessionFactory, createSessionFactory, createSessionFactory, createSessionFactory, createSessionFactory, disableFinalizeCheck, getAckBatchSize, getCallFailoverTimeout, getCallTimeout, getClientFailureCheckPeriod, getCompressionLevel, getConfirmationWindowSize, getConnectionLoadBalancingPolicyClassName, getConnectionTTL, getConsumerMaxRate, getConsumerWindowSize, getDiscoveryGroupConfiguration, getFailoverAttempts, getFlowControlThreadPoolMaxSize, getGroupID, getIncomingInterceptorList, getInitialConnectAttempts, getInitialMessagePacketSize, getLocatorConfig, getMaxRetryInterval, getMinLargeMessageSize, getOnMessageCloseTimeout, getOutgoingInterceptorList, getPasswordCodec, getProducerMaxRate, getProducerWindowSize, getProtocolManagerFactory, getReconnectAttempts, getRetryInterval, getRetryIntervalMultiplier, getScheduledThreadPoolMaxSize, getStaticTransportConfigurations, getThreadPoolMaxSize, getUseTopologyForLoadBalancing, initialize, isAutoGroup, isBlockOnAcknowledge, isBlockOnDurableSend, isBlockOnNonDurableSend, isCacheLargeMessagesClient, isClosed, isCompressLargeMessage, isFailoverOnInitialConnection, isHA, isPreAcknowledge, isUseGlobalPools, removeClusterTopologyListener, removeIncomingInterceptor, removeOutgoingInterceptor, setAckBatchSize, setAutoGroup, setBlockOnAcknowledge, setBlockOnDurableSend, setBlockOnNonDurableSend, setCacheLargeMessagesClient, setCallFailoverTimeout, setCallTimeout, setClientFailureCheckPeriod, setCompressionLevel, setCompressLargeMessage, setConfirmationWindowSize, setConnectionLoadBalancingPolicyClassName, setConnectionTTL, setConsumerMaxRate, setConsumerWindowSize, setFailoverAttempts, setFailoverOnInitialConnection, setFlowControlThreadPoolMaxSize, setGroupID, setIncomingInterceptorList, setInitialConnectAttempts, setInitialMessagePacketSize, setLocatorConfig, setMaxRetryInterval, setMinLargeMessageSize, setOnMessageCloseTimeout, setOutgoingInterceptorList, setPasswordCodec, setPreAcknowledge, setProducerMaxRate, setProducerWindowSize, setProtocolManagerFactory, setReconnectAttempts, setRetryInterval, setRetryIntervalMultiplier, setScheduledThreadPoolMaxSize, setThreadPoolMaxSize, setThreadPools, setUseGlobalPools, setUseTopologyForLoadBalancing

Method Details

start

void start(Executor executor)
    throws Exception

Throws:

Exception

factoryClosed

void factoryClosed(ClientSessionFactory factory)

getAfterConnectInternalListener

AfterConnectInternalListener getAfterConnectInternalListener()

setAfterConnectionInternalListener

ServerLocatorInternal setAfterConnectionInternalListener(AfterConnectInternalListener listener)

setDiscoveryListener

ServerLocatorInternal setDiscoveryListener(DiscoveryListener listener)

setIdentity

ServerLocatorInternal setIdentity(String identity)

Used to better identify Cluster Connection Locators on logs. To facilitate eventual debugging.

This method used to be on tests interface, but I'm now making it part of the public interface since

setNodeID

ServerLocatorInternal setNodeID(String nodeID)

getNodeID

String getNodeID()

cleanup

void cleanup()

resetToInitialConnectors

void resetToInitialConnectors()

connect

ClientSessionFactoryInternal connect()
                              throws ActiveMQException

Throws:

ActiveMQException

connectNoWarnings

ClientSessionFactoryInternal connectNoWarnings()
                                        throws ActiveMQException

Like connect() but it does not log warnings if it fails to connect.

Throws:

ActiveMQException

notifyNodeUp

void notifyNodeUp(long uniqueEventID,
 String nodeID,
 String backupGroupName,
 String scaleDownGroupName,
 Pair<TransportConfiguration,TransportConfiguration> connectorPair,
 boolean last)

notifyNodeDown

default void notifyNodeDown(long uniqueEventID,
 String nodeID)

Notify this about a node down event.

Parameters:

uniqueEventID - 0 means get the previous ID +1

notifyNodeDown

void notifyNodeDown(long uniqueEventID,
 String nodeID,
 boolean disconnect)

setClusterConnection

ServerLocatorInternal setClusterConnection(boolean clusterConnection)

isClusterConnection

boolean isClusterConnection()

getClusterTransportConfiguration

TransportConfiguration getClusterTransportConfiguration()

setClusterTransportConfiguration

ServerLocatorInternal setClusterTransportConfiguration(TransportConfiguration tc)

getTopology

Topology getTopology()

Description copied from interface: ServerLocator

Exposes the Topology used by this ServerLocator.

Specified by:

getTopology in interface ServerLocator

Returns:

topology

newProtocolManager

ClientProtocolManager newProtocolManager()

isConnectable

boolean isConnectable()

getConnectorsSize

int getConnectorsSize()

selectNextConnectorPair

Pair<TransportConfiguration,TransportConfiguration> selectNextConnectorPair()

getNextRetryInterval

long getNextRetryInterval(long retryInterval,
 double retryIntervalMultiplier,
 long maxRetryInterval)