com.hazelcast.enterprise.wan.connection

Class WanConnectionManager

java.lang.Object

com.hazelcast.enterprise.wan.connection.WanConnectionManager

All Implemented Interfaces:

com.hazelcast.nio.ConnectionListener

public class WanConnectionManager
extends Object
implements com.hazelcast.nio.ConnectionListener

Maintains connections for WAN replication for a single WanReplicationPublisher.

Constructor Summary

Constructors

Constructor and Description
WanConnectionManager(com.hazelcast.instance.Node node, com.hazelcast.spi.discovery.integration.DiscoveryService discoveryService)

Method Summary

Modifier and Type	Method and Description
List<com.hazelcast.nio.Address>	awaitAndGetTargetEndpoints() Returns a list of currently live endpoints.
void	connectionAdded(com.hazelcast.nio.Connection connection)
void	connectionRemoved(com.hazelcast.nio.Connection connection)
WanConnectionWrapper	getConnection(com.hazelcast.nio.Address target) Returns either the connection wrapper for the requested target or for the first target in the endpoint list if the provided target is not in the endpoint list.
List<com.hazelcast.nio.Address>	getTargetEndpoints() Return a snapshot of the list of currently known target endpoints to which replication is made.
void	init(WanConfigurationContext configurationContext) Initialise the connection manager.
boolean	isConnected() Tests if connected to a configured target cluster endpoint over WAN.
void	removeTargetEndpoint(com.hazelcast.nio.Address targetAddress, String reason, Throwable cause)
void	shutdown() Shuts down this connection manager.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WanConnectionManager

public WanConnectionManager(com.hazelcast.instance.Node node,
                            com.hazelcast.spi.discovery.integration.DiscoveryService discoveryService)

Method Detail

init

public void init(WanConfigurationContext configurationContext)

Initialise the connection manager. This will run discovery on the supplied DiscoveryService and schedule a task to rerun discovery.

Parameters:

configurationContext - the configuration context for the WAN publisher

awaitAndGetTargetEndpoints

public List<com.hazelcast.nio.Address> awaitAndGetTargetEndpoints()

Returns a list of currently live endpoints. It will sleep until the list contains at least one endpoint or running is false (this connection manager is shutting down) at which point it can return an empty list.

shutdown

public void shutdown()

Shuts down this connection manager.

getConnection

public WanConnectionWrapper getConnection(com.hazelcast.nio.Address target)

Returns either the connection wrapper for the requested target or for the first target in the endpoint list if the provided target is not in the endpoint list. The method may return null if this method fails to create a connection, either because it cannot connect in the expected time or it has failed to authorize. The method will check if the connection is alive before returning the wrapper.

Parameters:

target - the address for which a connection is requested

Returns:

connection to the target address, the first endpoint if the target is not in the endpoint list or null

isConnected

public boolean isConnected()

Tests if connected to a configured target cluster endpoint over WAN. This method iterates over the target endpoints until an alive connection is found or no endpoint is left to test.

Returns:

true if there is at least one alive connection, false otherwise

removeTargetEndpoint

public void removeTargetEndpoint(com.hazelcast.nio.Address targetAddress,
                                 String reason,
                                 Throwable cause)

getTargetEndpoints

public List<com.hazelcast.nio.Address> getTargetEndpoints()

Return a snapshot of the list of currently known target endpoints to which replication is made. Some of them can currently have dead connections and are about to be removed.

Returns:

the list of currently known target endpoints

See Also:

removeTargetEndpoint(Address, String, Throwable)

connectionAdded

public void connectionAdded(com.hazelcast.nio.Connection connection)

Specified by:

connectionAdded in interface com.hazelcast.nio.ConnectionListener

connectionRemoved

public void connectionRemoved(com.hazelcast.nio.Connection connection)

Specified by:

connectionRemoved in interface com.hazelcast.nio.ConnectionListener