public class ServerLocatorImpl extends Object implements ServerLocatorInternal, DiscoveryListener, Serializable
Modifier and Type | Field and Description |
---|---|
static Runnable |
finalizeCallback |
Constructor and Description |
---|
ServerLocatorImpl(boolean useHA,
DiscoveryGroupConfiguration groupConfiguration)
Create a ServerLocatorImpl using UDP discovery to lookup cluster
|
ServerLocatorImpl(boolean useHA,
TransportConfiguration... transportConfigs)
Create a ServerLocatorImpl using a static list of live servers
|
ServerLocatorImpl(Topology topology,
boolean useHA,
DiscoveryGroupConfiguration groupConfiguration)
Create a ServerLocatorImpl using UDP discovery to lookup cluster
|
ServerLocatorImpl(Topology topology,
boolean useHA,
TransportConfiguration... transportConfigs)
Create a ServerLocatorImpl using a static list of live servers
|
Modifier and Type | Method and Description |
---|---|
void |
addClusterTopologyListener(ClusterTopologyListener listener) |
void |
addInterceptor(Interceptor interceptor)
Adds an interceptor which will be executed after packets are received from the server.
|
void |
cleanup() |
static void |
clearThreadPools() |
void |
close()
Closes this factory and release all its resources
|
ClientSessionFactoryInternal |
connect() |
void |
connectorsChanged() |
ClientSessionFactory |
createSessionFactory()
Create a ClientSessionFactory using whatever load balancing policy is in force
|
ClientSessionFactory |
createSessionFactory(String nodeID)
Create a ClientSessionFactory to a specific server.
|
ClientSessionFactory |
createSessionFactory(TransportConfiguration transportConfiguration)
Create a ClientSessionFactory to a specific server.
|
void |
disableFinalizeCheck()
This method will disable any checks when a GarbageCollection happens
leaving connections open.
|
protected void |
doClose(boolean sendClose) |
void |
factoryClosed(ClientSessionFactory factory) |
protected void |
finalize() |
int |
getAckBatchSize()
Returns the acknowledgments batch size.
|
AfterConnectInternalListener |
getAfterConnectInternalListener() |
long |
getCallTimeout()
Returns the blocking calls timeout.
|
long |
getClientFailureCheckPeriod()
Returns the period used to check if a client has failed to receive pings from the server.
|
TransportConfiguration |
getClusterTransportConfiguration() |
int |
getConfirmationWindowSize()
Returns the size for the confirmation window of clients using this factory.
|
String |
getConnectionLoadBalancingPolicyClassName()
Returns the class name of the connection load balancing policy.
|
long |
getConnectionTTL()
Returns the connection time-to-live.
|
int |
getConsumerMaxRate()
Returns the maximum rate of message consumption for consumers created through this factory.
|
int |
getConsumerWindowSize()
Returns the window size for flow control of the consumers created through this factory.
|
DiscoveryGroupConfiguration |
getDiscoveryGroupConfiguration()
The discovery group configuration
|
Executor |
getExecutor() |
static ScheduledExecutorService |
getGlobalScheduledThreadPool() |
String |
getGroupID()
Returns the group ID that will be eventually set on each message for the property
Message.HDR_GROUP_ID . |
String |
getIdentity() |
int |
getInitialConnectAttempts() |
int |
getInitialMessagePacketSize()
Returns the initial size of messages created through this factory.
|
long |
getMaxRetryInterval()
Returns the maximum retry interval (in the case a retry interval multiplier has been specified).
|
int |
getMinLargeMessageSize()
Returns the large message size threshold.
|
String |
getNodeID() |
int |
getProducerMaxRate()
Returns the maximum rate of message production for producers created through this factory.
|
int |
getProducerWindowSize()
Returns the window size for flow control of the producers created through this factory.
|
int |
getReconnectAttempts()
Returns the maximum number of attempts to retry connection in case of failure.
|
long |
getRetryInterval()
Returns the time to retry connections created by this factory after failure.
|
double |
getRetryIntervalMultiplier()
Returns the multiplier to apply to successive retry intervals.
|
int |
getScheduledThreadPoolMaxSize()
Returns the maximum size of the scheduled thread pool.
|
TransportConfiguration[] |
getStaticTransportConfigurations()
Returns an array of TransportConfigurations representing the static list of live servers used when
creating this object
|
int |
getThreadPoolMaxSize()
Returns the maximum size of the thread pool.
|
Topology |
getTopology() |
boolean |
isAutoGroup()
Returns whether producers created through this factory will automatically
assign a group ID to the messages they sent.
|
boolean |
isBackup() |
boolean |
isBlockOnAcknowledge()
Returns whether consumers created through this factory will block while
sending message acknowledgments or do it asynchronously.
|
boolean |
isBlockOnDurableSend()
Returns whether producers created through this factory will block while sending durable messages or do it asynchronously.
|
boolean |
isBlockOnNonDurableSend()
Returns whether producers created through this factory will block while sending non-durable messages or do it asynchronously.
|
boolean |
isCacheLargeMessagesClient()
When
true , consumers created through this factory will create temporary files to cache large messages. |
boolean |
isClosed()
Returns true if close was already called
|
boolean |
isClusterConnection() |
boolean |
isCompressLargeMessage() |
boolean |
isFailoverOnInitialConnection()
Returns true if the client will automatically attempt to connect to the backup server if the initial
connection to the live server fails
Default value is
HornetQClient.DEFAULT_FAILOVER_ON_INITIAL_CONNECTION . |
boolean |
isHA() |
boolean |
isPreAcknowledge()
Returns whether messages will pre-acknowledged on the server before they are sent to the consumers or not.
|
boolean |
isUseGlobalPools()
Returns whether this factory will use global thread pools (shared among all the factories in the same JVM)
or its own pools.
|
void |
notifyNodeDown(long eventTime,
String nodeID)
This is directly called when the connection to the node is gone,
or when the node sends a disconnection.
|
void |
notifyNodeUp(long uniqueEventID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
void |
removeClusterTopologyListener(ClusterTopologyListener listener) |
boolean |
removeInterceptor(Interceptor interceptor)
Removes an interceptor.
|
void |
setAckBatchSize(int ackBatchSize)
Sets the acknowledgments batch size.
|
void |
setAfterConnectionInternalListener(AfterConnectInternalListener listener) |
void |
setAutoGroup(boolean autoGroup)
Sets whether producers created through this factory will automatically
assign a group ID to the messages they sent.
|
void |
setBackup(boolean backup) |
void |
setBlockOnAcknowledge(boolean blockOnAcknowledge)
Sets whether consumers created through this factory will block while
sending message acknowledgments or do it asynchronously.
|
void |
setBlockOnDurableSend(boolean blockOnDurableSend)
Sets whether producers created through this factory will block while sending durable messages or do it asynchronously.
|
void |
setBlockOnNonDurableSend(boolean blockOnNonDurableSend)
Sets whether producers created through this factory will block while sending non-durable messages or do it asynchronously.
|
void |
setCacheLargeMessagesClient(boolean cached)
Sets whether large messages received by consumers created through this factory will be cached in temporary files or not.
|
void |
setCallTimeout(long callTimeout)
Sets the blocking call timeout.
|
void |
setClientFailureCheckPeriod(long clientFailureCheckPeriod)
Sets the period (in milliseconds) used to check if a client has failed to receive pings from the server.
|
void |
setClusterConnection(boolean clusterConnection) |
void |
setClusterTransportConfiguration(TransportConfiguration tc) |
void |
setCompressLargeMessage(boolean compress) |
void |
setConfirmationWindowSize(int confirmationWindowSize)
Sets the size for the confirmation window buffer of clients using this factory.
|
void |
setConnectionLoadBalancingPolicyClassName(String loadBalancingPolicyClassName)
Sets the class name of the connection load balancing policy.
|
void |
setConnectionTTL(long connectionTTL)
Sets this factory's connections time-to-live.
|
void |
setConsumerMaxRate(int consumerMaxRate)
Sets the maximum rate of message consumption for consumers created through this factory.
|
void |
setConsumerWindowSize(int consumerWindowSize)
Sets the window size for flow control of the consumers created through this factory.
|
void |
setFailoverOnInitialConnection(boolean failover)
Sets the value for FailoverOnInitialReconnection
|
void |
setGroupID(String groupID)
Sets the group ID that will be set on each message sent through this factory.
|
void |
setIdentity(String identity)
Used to better identify Cluster Connection Locators on logs.
|
void |
setInitialConnectAttempts(int initialConnectAttempts) |
void |
setInitialMessagePacketSize(int size)
Sets the initial size of messages created through this factory.
|
void |
setMaxRetryInterval(long retryInterval)
Sets the maximum retry interval.
|
void |
setMinLargeMessageSize(int minLargeMessageSize)
Sets the large message size threshold.
|
void |
setNodeID(String nodeID) |
void |
setPreAcknowledge(boolean preAcknowledge)
Sets to
true to pre-acknowledge consumed messages on the
server before they are sent to consumers, else set to false
to let clients acknowledge the message they consume. |
void |
setProducerMaxRate(int producerMaxRate)
Sets the maximum rate of message production for producers created through this factory.
|
void |
setProducerWindowSize(int producerWindowSize)
Returns the window size for flow control of the producers created through this factory.
|
void |
setReconnectAttempts(int reconnectAttempts)
Sets the maximum number of attempts to retry connection in case of failure.
|
void |
setRetryInterval(long retryInterval)
Sets the time to retry connections created by this factory after failure.
|
void |
setRetryIntervalMultiplier(double retryIntervalMultiplier)
Sets the multiplier to apply to successive retry intervals.
|
void |
setScheduledThreadPoolMaxSize(int scheduledThreadPoolMaxSize)
Sets the maximum size of the scheduled thread pool.
|
void |
setThreadPoolMaxSize(int threadPoolMaxSize)
Sets the maximum size of the thread pool.
|
void |
setUseGlobalPools(boolean useGlobalPools)
Sets whether this factory will use global thread pools (shared among all the factories in the same JVM)
or its own pools.
|
void |
start(Executor executor) |
String |
toString() |
public static Runnable finalizeCallback
public ServerLocatorImpl(boolean useHA, DiscoveryGroupConfiguration groupConfiguration)
discoveryAddress
- discoveryPort
- public ServerLocatorImpl(boolean useHA, TransportConfiguration... transportConfigs)
transportConfigs
- public ServerLocatorImpl(Topology topology, boolean useHA, DiscoveryGroupConfiguration groupConfiguration)
discoveryAddress
- discoveryPort
- public ServerLocatorImpl(Topology topology, boolean useHA, TransportConfiguration... transportConfigs)
transportConfigs
- public static void clearThreadPools()
public static ScheduledExecutorService getGlobalScheduledThreadPool()
public void start(Executor executor) throws Exception
start
in interface ServerLocatorInternal
Exception
public Executor getExecutor()
getExecutor
in interface ServerLocatorInternal
public void disableFinalizeCheck()
ServerLocator
disableFinalizeCheck
in interface ServerLocator
public ClientSessionFactoryInternal connect() throws Exception
connect
in interface ServerLocatorInternal
Exception
public void setAfterConnectionInternalListener(AfterConnectInternalListener listener)
setAfterConnectionInternalListener
in interface ServerLocatorInternal
public AfterConnectInternalListener getAfterConnectInternalListener()
getAfterConnectInternalListener
in interface ServerLocatorInternal
public ClientSessionFactory createSessionFactory(String nodeID) throws Exception
ServerLocator
createSessionFactory
in interface ServerLocator
Exception
- if a failure happened in creating the ClientSessionFactory or the ServerLocator does not know about the passed in transportConfigurationpublic ClientSessionFactory createSessionFactory(TransportConfiguration transportConfiguration) throws Exception
ServerLocator
createSessionFactory
in interface ServerLocator
Exception
- if a failure happened in creating the ClientSessionFactory or the ServerLocator does not know about the passed in transportConfigurationpublic ClientSessionFactory createSessionFactory() throws Exception
ServerLocator
createSessionFactory
in interface ServerLocator
Exception
public boolean isHA()
isHA
in interface ServerLocator
public boolean isCacheLargeMessagesClient()
ServerLocator
true
, consumers created through this factory will create temporary files to cache large messages.
There is 1 temporary file created for each large message.
Default value is HornetQClient.DEFAULT_CACHE_LARGE_MESSAGE_CLIENT
.isCacheLargeMessagesClient
in interface ServerLocator
true
if consumers created through this factory will cache large messages in temporary files, false
elsepublic void setCacheLargeMessagesClient(boolean cached)
ServerLocator
setCacheLargeMessagesClient
in interface ServerLocator
cached
- true
to cache large messages in temporary files, false
elsepublic long getClientFailureCheckPeriod()
ServerLocator
HornetQClient.DEFAULT_CLIENT_FAILURE_CHECK_PERIOD
.getClientFailureCheckPeriod
in interface ServerLocator
public void setClientFailureCheckPeriod(long clientFailureCheckPeriod)
ServerLocator
setClientFailureCheckPeriod
in interface ServerLocator
clientFailureCheckPeriod
- the period to check failurepublic long getConnectionTTL()
ServerLocator
HornetQClient.DEFAULT_CONNECTION_TTL
.getConnectionTTL
in interface ServerLocator
public void setConnectionTTL(long connectionTTL)
ServerLocator
setConnectionTTL
in interface ServerLocator
connectionTTL
- period in millisecondspublic long getCallTimeout()
ServerLocator
HornetQException
with the code HornetQException.CONNECTION_TIMEDOUT
.
Value is in milliseconds, default value is HornetQClient.DEFAULT_CALL_TIMEOUT
.getCallTimeout
in interface ServerLocator
public void setCallTimeout(long callTimeout)
ServerLocator
setCallTimeout
in interface ServerLocator
callTimeout
- blocking call timeout in millisecondspublic int getMinLargeMessageSize()
ServerLocator
HornetQClient.DEFAULT_MIN_LARGE_MESSAGE_SIZE
.getMinLargeMessageSize
in interface ServerLocator
public void setMinLargeMessageSize(int minLargeMessageSize)
ServerLocator
setMinLargeMessageSize
in interface ServerLocator
minLargeMessageSize
- large message size threshold in bytespublic int getConsumerWindowSize()
ServerLocator
HornetQClient.DEFAULT_CONSUMER_WINDOW_SIZE
.getConsumerWindowSize
in interface ServerLocator
public void setConsumerWindowSize(int consumerWindowSize)
ServerLocator
setConsumerWindowSize
in interface ServerLocator
consumerWindowSize
- window size (in bytes) used for consumer flow controlpublic int getConsumerMaxRate()
ServerLocator
HornetQClient.DEFAULT_CONSUMER_MAX_RATE
.getConsumerMaxRate
in interface ServerLocator
public void setConsumerMaxRate(int consumerMaxRate)
ServerLocator
setConsumerMaxRate
in interface ServerLocator
consumerMaxRate
- maximum rate of message consumption (in messages per seconds)public int getConfirmationWindowSize()
ServerLocator
HornetQClient.DEFAULT_CONFIRMATION_WINDOW_SIZE
.getConfirmationWindowSize
in interface ServerLocator
public void setConfirmationWindowSize(int confirmationWindowSize)
ServerLocator
setConfirmationWindowSize
in interface ServerLocator
confirmationWindowSize
- size of the confirmation window (in bytes)public int getProducerWindowSize()
ServerLocator
HornetQClient.DEFAULT_PRODUCER_WINDOW_SIZE
.getProducerWindowSize
in interface ServerLocator
public void setProducerWindowSize(int producerWindowSize)
ServerLocator
setProducerWindowSize
in interface ServerLocator
producerWindowSize
- window size (in bytest) for flow control of the producers created through this factory.public int getProducerMaxRate()
ServerLocator
HornetQClient.DEFAULT_PRODUCER_MAX_RATE
.getProducerMaxRate
in interface ServerLocator
public void setProducerMaxRate(int producerMaxRate)
ServerLocator
setProducerMaxRate
in interface ServerLocator
producerMaxRate
- maximum rate of message production (in messages per seconds)public boolean isBlockOnAcknowledge()
ServerLocator
HornetQClient.DEFAULT_BLOCK_ON_ACKNOWLEDGE
.isBlockOnAcknowledge
in interface ServerLocator
public void setBlockOnAcknowledge(boolean blockOnAcknowledge)
ServerLocator
setBlockOnAcknowledge
in interface ServerLocator
blockOnAcknowledge
- true
to block when sending message
acknowledgments or false
to send them
asynchronouslypublic boolean isBlockOnDurableSend()
ServerLocator
HornetQClient.DEFAULT_BLOCK_ON_DURABLE_SEND
.isBlockOnDurableSend
in interface ServerLocator
public void setBlockOnDurableSend(boolean blockOnDurableSend)
ServerLocator
setBlockOnDurableSend
in interface ServerLocator
blockOnDurableSend
- true
to block when sending durable messages or false
to send them asynchronouslypublic boolean isBlockOnNonDurableSend()
ServerLocator
HornetQClient.DEFAULT_BLOCK_ON_NON_DURABLE_SEND
.isBlockOnNonDurableSend
in interface ServerLocator
public void setBlockOnNonDurableSend(boolean blockOnNonDurableSend)
ServerLocator
setBlockOnNonDurableSend
in interface ServerLocator
blockOnNonDurableSend
- true
to block when sending non-durable messages or false
to send them asynchronouslypublic boolean isAutoGroup()
ServerLocator
true
, a random unique group ID is created and set on each message for the property
Message.HDR_GROUP_ID
.
Default value is HornetQClient.DEFAULT_AUTO_GROUP
.isAutoGroup
in interface ServerLocator
public void setAutoGroup(boolean autoGroup)
ServerLocator
setAutoGroup
in interface ServerLocator
autoGroup
- true
to automatically assign a group ID to each messages sent through this factory, false
elsepublic boolean isPreAcknowledge()
ServerLocator
HornetQClient.DEFAULT_PRE_ACKNOWLEDGE
isPreAcknowledge
in interface ServerLocator
public void setPreAcknowledge(boolean preAcknowledge)
ServerLocator
true
to pre-acknowledge consumed messages on the
server before they are sent to consumers, else set to false
to let clients acknowledge the message they consume.setPreAcknowledge
in interface ServerLocator
preAcknowledge
- true
to enable pre-acknowledgment,
false
elsepublic int getAckBatchSize()
ServerLocator
HornetQClient.DEFAULT_ACK_BATCH_SIZE
.getAckBatchSize
in interface ServerLocator
public void setAckBatchSize(int ackBatchSize)
ServerLocator
setAckBatchSize
in interface ServerLocator
ackBatchSize
- acknowledgments batch sizepublic boolean isUseGlobalPools()
ServerLocator
HornetQClient.DEFAULT_USE_GLOBAL_POOLS
.isUseGlobalPools
in interface ServerLocator
true
if this factory uses global thread pools, false
elsepublic void setUseGlobalPools(boolean useGlobalPools)
ServerLocator
setUseGlobalPools
in interface ServerLocator
useGlobalPools
- true
to let this factory uses global thread pools, false
elsepublic int getScheduledThreadPoolMaxSize()
ServerLocator
HornetQClient.DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE
.getScheduledThreadPoolMaxSize
in interface ServerLocator
public void setScheduledThreadPoolMaxSize(int scheduledThreadPoolMaxSize)
ServerLocator
setScheduledThreadPoolMaxSize
in interface ServerLocator
scheduledThreadPoolMaxSize
- maximum size of the scheduled thread pool.public int getThreadPoolMaxSize()
ServerLocator
HornetQClient.DEFAULT_THREAD_POOL_MAX_SIZE
.getThreadPoolMaxSize
in interface ServerLocator
public void setThreadPoolMaxSize(int threadPoolMaxSize)
ServerLocator
setThreadPoolMaxSize
in interface ServerLocator
threadPoolMaxSize
- maximum size of the thread pool.public long getRetryInterval()
ServerLocator
HornetQClient.DEFAULT_RETRY_INTERVAL
.getRetryInterval
in interface ServerLocator
public void setRetryInterval(long retryInterval)
ServerLocator
setRetryInterval
in interface ServerLocator
retryInterval
- time (in milliseconds) to retry connections created by this factory after failurepublic long getMaxRetryInterval()
ServerLocator
HornetQClient.DEFAULT_MAX_RETRY_INTERVAL
.getMaxRetryInterval
in interface ServerLocator
public void setMaxRetryInterval(long retryInterval)
ServerLocator
setMaxRetryInterval
in interface ServerLocator
retryInterval
- maximum retry interval to apply in the case a retry interval multiplier has been specifiedpublic double getRetryIntervalMultiplier()
ServerLocator
HornetQClient.DEFAULT_RETRY_INTERVAL_MULTIPLIER
.getRetryIntervalMultiplier
in interface ServerLocator
public void setRetryIntervalMultiplier(double retryIntervalMultiplier)
ServerLocator
setRetryIntervalMultiplier
in interface ServerLocator
retryIntervalMultiplier
- multiplier to apply to successive retry intervalspublic int getReconnectAttempts()
ServerLocator
HornetQClient.DEFAULT_RECONNECT_ATTEMPTS
.getReconnectAttempts
in interface ServerLocator
public void setReconnectAttempts(int reconnectAttempts)
ServerLocator
setReconnectAttempts
in interface ServerLocator
reconnectAttempts
- maximum number of attempts to retry connection in case of failurepublic void setInitialConnectAttempts(int initialConnectAttempts)
setInitialConnectAttempts
in interface ServerLocator
public int getInitialConnectAttempts()
getInitialConnectAttempts
in interface ServerLocator
public boolean isFailoverOnInitialConnection()
ServerLocator
HornetQClient.DEFAULT_FAILOVER_ON_INITIAL_CONNECTION
.isFailoverOnInitialConnection
in interface ServerLocator
public void setFailoverOnInitialConnection(boolean failover)
ServerLocator
setFailoverOnInitialConnection
in interface ServerLocator
public String getConnectionLoadBalancingPolicyClassName()
ServerLocator
getConnectionLoadBalancingPolicyClassName
in interface ServerLocator
public void setConnectionLoadBalancingPolicyClassName(String loadBalancingPolicyClassName)
ServerLocator
ConnectionLoadBalancingPolicy
.setConnectionLoadBalancingPolicyClassName
in interface ServerLocator
loadBalancingPolicyClassName
- class name of the connection load balancing policypublic TransportConfiguration[] getStaticTransportConfigurations()
ServerLocator
getStaticTransportConfigurations
in interface ServerLocator
public DiscoveryGroupConfiguration getDiscoveryGroupConfiguration()
ServerLocator
getDiscoveryGroupConfiguration
in interface ServerLocator
public void addInterceptor(Interceptor interceptor)
ServerLocator
addInterceptor
in interface ServerLocator
interceptor
- an Interceptorpublic boolean removeInterceptor(Interceptor interceptor)
ServerLocator
removeInterceptor
in interface ServerLocator
interceptor
- interceptor to removetrue
if the interceptor is removed from this factory, false
elsepublic int getInitialMessagePacketSize()
ServerLocator
HornetQClient.DEFAULT_INITIAL_MESSAGE_PACKET_SIZE
.getInitialMessagePacketSize
in interface ServerLocator
public void setInitialMessagePacketSize(int size)
ServerLocator
setInitialMessagePacketSize
in interface ServerLocator
size
- initial size of messages created through this factory.public void setGroupID(String groupID)
ServerLocator
setGroupID
in interface ServerLocator
groupID
- the group ID to usepublic String getGroupID()
ServerLocator
Message.HDR_GROUP_ID
.
Default value is is null
and no group ID will be set on the messages.getGroupID
in interface ServerLocator
public boolean isCompressLargeMessage()
isCompressLargeMessage
in interface ServerLocator
public void setCompressLargeMessage(boolean compress)
setCompressLargeMessage
in interface ServerLocator
public String getIdentity()
getIdentity
in interface ServerLocatorInternal
public void setIdentity(String identity)
ServerLocatorInternal
setIdentity
in interface ServerLocatorInternal
public void setNodeID(String nodeID)
setNodeID
in interface ServerLocatorInternal
public String getNodeID()
getNodeID
in interface ServerLocatorInternal
public void setClusterConnection(boolean clusterConnection)
setClusterConnection
in interface ServerLocatorInternal
public boolean isClusterConnection()
isClusterConnection
in interface ServerLocatorInternal
public TransportConfiguration getClusterTransportConfiguration()
getClusterTransportConfiguration
in interface ServerLocatorInternal
public void setClusterTransportConfiguration(TransportConfiguration tc)
setClusterTransportConfiguration
in interface ServerLocatorInternal
public boolean isBackup()
isBackup
in interface ServerLocatorInternal
public void setBackup(boolean backup)
setBackup
in interface ServerLocatorInternal
protected void finalize() throws Throwable
public void cleanup()
cleanup
in interface ServerLocatorInternal
public void close()
ServerLocator
close
in interface ServerLocator
protected void doClose(boolean sendClose)
public void notifyNodeDown(long eventTime, String nodeID)
notifyNodeDown
in interface ServerLocatorInternal
eventTime
- 0 means get the previous ID +1public void notifyNodeUp(long uniqueEventID, String nodeID, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean last)
notifyNodeUp
in interface ServerLocatorInternal
public void connectorsChanged()
connectorsChanged
in interface DiscoveryListener
public void factoryClosed(ClientSessionFactory factory)
factoryClosed
in interface ServerLocatorInternal
public Topology getTopology()
getTopology
in interface ServerLocatorInternal
public void addClusterTopologyListener(ClusterTopologyListener listener)
addClusterTopologyListener
in interface ServerLocator
public void removeClusterTopologyListener(ClusterTopologyListener listener)
removeClusterTopologyListener
in interface ServerLocator
public boolean isClosed()
ServerLocator
isClosed
in interface ServerLocator
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.