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 and 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()
String	getNodeID()
Topology	getTopology() Exposes the Topology used by this ServerLocator.
boolean	isClusterConnection()
boolean	isConnectable()
ClientProtocolManager	newProtocolManager()
void	notifyNodeDown(long uniqueEventID, String nodeID)
void	notifyNodeUp(long uniqueEventID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean last)
void	resetToInitialConnectors()
ServerLocatorInternal	setAfterConnectionInternalListener(AfterConnectInternalListener listener)
ServerLocatorInternal	setClusterConnection(boolean clusterConnection)
ServerLocatorInternal	setClusterTransportConfiguration(TransportConfiguration tc)
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, disableFinalizeCheck, getAckBatchSize, getCallFailoverTimeout, getCallTimeout, getClientFailureCheckPeriod, getConfirmationWindowSize, getConnectionLoadBalancingPolicyClassName, getConnectionTTL, getConsumerMaxRate, getConsumerWindowSize, getDiscoveryGroupConfiguration, getGroupID, getIncomingInterceptorList, getInitialConnectAttempts, getInitialMessagePacketSize, getMaxRetryInterval, getMinLargeMessageSize, getOutgoingInterceptorList, getProducerMaxRate, getProducerWindowSize, getProtocolManagerFactory, getReconnectAttempts, getRetryInterval, getRetryIntervalMultiplier, getScheduledThreadPoolMaxSize, getStaticTransportConfigurations, getThreadPoolMaxSize, isAutoGroup, isBlockOnAcknowledge, isBlockOnDurableSend, isBlockOnNonDurableSend, isCacheLargeMessagesClient, isClosed, isCompressLargeMessage, isFailoverOnInitialConnection, isHA, isPreAcknowledge, isUseGlobalPools, removeClusterTopologyListener, removeIncomingInterceptor, removeOutgoingInterceptor, setAckBatchSize, setAutoGroup, setBlockOnAcknowledge, setBlockOnDurableSend, setBlockOnNonDurableSend, setCacheLargeMessagesClient, setCallFailoverTimeout, setCallTimeout, setClientFailureCheckPeriod, setCompressLargeMessage, setConfirmationWindowSize, setConnectionLoadBalancingPolicyClassName, setConnectionTTL, setConsumerMaxRate, setConsumerWindowSize, setFailoverOnInitialConnection, setGroupID, setIncomingInterceptorList, setInitialConnectAttempts, setInitialMessagePacketSize, setMaxRetryInterval, setMinLargeMessageSize, setOutgoingInterceptorList, setPreAcknowledge, setProducerMaxRate, setProducerWindowSize, setProtocolManagerFactory, setReconnectAttempts, setRetryInterval, setRetryIntervalMultiplier, setScheduledThreadPoolMaxSize, setThreadPoolMaxSize, setThreadPools, setUseGlobalPools

Method Detail

start

void start(Executor executor)
    throws Exception

Throws:

Exception

factoryClosed

void factoryClosed(ClientSessionFactory factory)

getAfterConnectInternalListener

AfterConnectInternalListener getAfterConnectInternalListener()

setAfterConnectionInternalListener

ServerLocatorInternal setAfterConnectionInternalListener(AfterConnectInternalListener 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

void notifyNodeDown(long uniqueEventID,
                    String nodeID)

Parameters:

uniqueEventID - 0 means get the previous ID +1

nodeID -

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()