org.hornetq.core.client.impl

Interface ServerLocatorInternal

All Superinterfaces:

AutoCloseable, ServerLocator

All Known Implementing Classes:

ServerLocatorImpl

public interface ServerLocatorInternal
extends ServerLocator

A ServerLocatorInternal

Author:

Tim Fox

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()
void	notifyNodeDown(long uniqueEventID, String nodeID)
void	notifyNodeUp(long uniqueEventID, String nodeID, String nodeName, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean last)
void	resetToInitialConnectors()
void	setAfterConnectionInternalListener(AfterConnectInternalListener listener)
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	setPacketDecoder(PacketDecoder instance)
void	start(Executor executor)

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

addClusterTopologyListener, addIncomingInterceptor, addInterceptor, addOutgoingInterceptor, close, createSessionFactory, createSessionFactory, createSessionFactory, createSessionFactory, disableFinalizeCheck, getAckBatchSize, getCallFailoverTimeout, 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, removeIncomingInterceptor, removeInterceptor, removeOutgoingInterceptor, setAckBatchSize, setAutoGroup, setBlockOnAcknowledge, setBlockOnDurableSend, setBlockOnNonDurableSend, setCacheLargeMessagesClient, setCallFailoverTimeout, 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

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

setNodeID

void setNodeID(String nodeID)

getNodeID

String getNodeID()

cleanup

void cleanup()

resetToInitialConnectors

void resetToInitialConnectors()

connect

ClientSessionFactoryInternal connect()
                              throws HornetQException

Throws:

HornetQException

connectNoWarnings

ClientSessionFactoryInternal connectNoWarnings()
                                        throws HornetQException

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

Throws:

HornetQException

notifyNodeUp

void notifyNodeUp(long uniqueEventID,
                  String nodeID,
                  String nodeName,
                  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)

getTopology

Topology getTopology()

Description copied from interface: ServerLocator

Exposes the Topology used by this ServerLocator.

Specified by:

getTopology in interface ServerLocator

Returns:

topology

setPacketDecoder

void setPacketDecoder(PacketDecoder instance)