com.hazelcast.enterprise.wan.connection

Class WanConnectionManager

java.lang.Object

com.hazelcast.enterprise.wan.connection.WanConnectionManager

public class WanConnectionManager
extends Object

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
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(String groupName, 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)

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(String groupName,
                 WanConfigurationContext configurationContext)

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

Parameters:

groupName - the group name for the discovered endpoints

configurationContext - the configuration context for the WAN publisher

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)