org.hornetq.core.client.impl

Interface ServerLocatorInternal

All Superinterfaces:

ServerLocator

All Known Implementing Classes:

ServerLocatorImpl

public interface ServerLocatorInternal
extends ServerLocator

A ServerLocatorInternal

Author:

Tim Fox

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup()
ClientSessionFactoryInternal	connect()
void	factoryClosed(ClientSessionFactory factory)
AfterConnectInternalListener	getAfterConnectInternalListener()
TransportConfiguration	getClusterTransportConfiguration()
Executor	getExecutor()
String	getIdentity()
String	getNodeID()
Topology	getTopology()
boolean	isBackup()
boolean	isClusterConnection()
void	notifyNodeDown(long uniqueEventID, String nodeID)
void	notifyNodeUp(long uniqueEventID, String nodeID, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean last)
void	setAfterConnectionInternalListener(AfterConnectInternalListener listener)
void	setBackup(boolean backup)
void	setClusterConnection(boolean clusterConnection)
void	setClusterTransportConfiguration(TransportConfiguration tc)
void	setIdentity(String identity) Used to better identify Cluster Connection Locators on logs.
void	setNodeID(String nodeID)
void	start(Executor executor)

Methods inherited from interface org.hornetq.api.core.client.ServerLocator

addClusterTopologyListener, addInterceptor, close, createSessionFactory, createSessionFactory, createSessionFactory, disableFinalizeCheck, getAckBatchSize, getCallTimeout, getClientFailureCheckPeriod, getConfirmationWindowSize, getConnectionLoadBalancingPolicyClassName, getConnectionTTL, getConsumerMaxRate, getConsumerWindowSize, getDiscoveryGroupConfiguration, getGroupID, getInitialConnectAttempts, getInitialMessagePacketSize, getMaxRetryInterval, getMinLargeMessageSize, getProducerMaxRate, getProducerWindowSize, getReconnectAttempts, getRetryInterval, getRetryIntervalMultiplier, getScheduledThreadPoolMaxSize, getStaticTransportConfigurations, getThreadPoolMaxSize, isAutoGroup, isBlockOnAcknowledge, isBlockOnDurableSend, isBlockOnNonDurableSend, isCacheLargeMessagesClient, isClosed, isCompressLargeMessage, isFailoverOnInitialConnection, isHA, isPreAcknowledge, isUseGlobalPools, removeClusterTopologyListener, removeInterceptor, setAckBatchSize, setAutoGroup, setBlockOnAcknowledge, setBlockOnDurableSend, setBlockOnNonDurableSend, setCacheLargeMessagesClient, setCallTimeout, setClientFailureCheckPeriod, setCompressLargeMessage, setConfirmationWindowSize, setConnectionLoadBalancingPolicyClassName, setConnectionTTL, setConsumerMaxRate, setConsumerWindowSize, setFailoverOnInitialConnection, setGroupID, setInitialConnectAttempts, setInitialMessagePacketSize, setMaxRetryInterval, setMinLargeMessageSize, setPreAcknowledge, setProducerMaxRate, setProducerWindowSize, setReconnectAttempts, setRetryInterval, setRetryIntervalMultiplier, setScheduledThreadPoolMaxSize, setThreadPoolMaxSize, setUseGlobalPools

Method Detail

start

void start(Executor executor)
           throws Exception

Throws:

Exception

getExecutor

Executor getExecutor()

factoryClosed

void factoryClosed(ClientSessionFactory factory)

getAfterConnectInternalListener

AfterConnectInternalListener getAfterConnectInternalListener()

setAfterConnectionInternalListener

void setAfterConnectionInternalListener(AfterConnectInternalListener listener)

setIdentity

void 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

getIdentity

String getIdentity()

setNodeID

void setNodeID(String nodeID)

getNodeID

String getNodeID()

cleanup

void cleanup()

connect

ClientSessionFactoryInternal connect()
                                     throws Exception

Throws:

Exception

notifyNodeUp

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

notifyNodeDown

void notifyNodeDown(long uniqueEventID,
                  String nodeID)

Parameters:

uniqueEventID - 0 means get the previous ID +1

nodeID -

setClusterConnection

void setClusterConnection(boolean clusterConnection)

isClusterConnection

boolean isClusterConnection()

getClusterTransportConfiguration

TransportConfiguration getClusterTransportConfiguration()

setClusterTransportConfiguration

void setClusterTransportConfiguration(TransportConfiguration tc)

isBackup

boolean isBackup()

setBackup

void setBackup(boolean backup)

getTopology

Topology getTopology()