com.hazelcast.enterprise.wan.replication

Class AbstractWanReplication

java.lang.Object

com.hazelcast.enterprise.wan.replication.AbstractWanPublisher

com.hazelcast.enterprise.wan.replication.AbstractWanReplication

All Implemented Interfaces:

WanReplicationEndpoint, com.hazelcast.spi.LiveOperationsTracker, com.hazelcast.wan.WanReplicationPublisher

Direct Known Subclasses:

WanBatchReplication

public abstract class AbstractWanReplication
extends AbstractWanPublisher

Abstract WAN event publisher implementation.

Field Summary

Fields

Modifier and Type	Field and Description
protected WanConnectionManager	connectionManager

Fields inherited from class com.hazelcast.enterprise.wan.replication.AbstractWanPublisher

configurationContext, eventQueueContainer, lastQueueFullLogTimeMs, localGroupName, logger, node, paused, queueCapacity, queueFullBehavior, queueLoggerTimePeriodMs, running, stagingQueue, syncManager, syncRequests, targetGroupName, wanReplicationName

Constructor Summary

Constructors

Constructor and Description
AbstractWanReplication()

Method Summary

Modifier and Type	Method and Description
protected void	afterShutdown()
List<com.hazelcast.nio.Address>	getTargetEndpoints() Return a snapshot of the list of currently known target endpoints to which replication is made.
void	init(com.hazelcast.instance.Node node, com.hazelcast.config.WanReplicationConfig wanReplicationConfig, com.hazelcast.config.WanPublisherConfig publisherConfig) Initializes the endpoint using the given arguments.
boolean	isConnected() Tests is there is at least one alive connection to a configured target cluster member over WAN.

Methods inherited from class com.hazelcast.enterprise.wan.replication.AbstractWanPublisher

addCacheQueue, addMapQueue, checkWanReplicationQueues, clearQueues, collectAllServiceNamespaces, collectReplicationData, decrementWANQueueSize, getCurrentBackupElementCount, getCurrentElementCount, getPartitionId, getPublisherQueueContainer, getStagingQueueSize, getStats, getTargetGroupName, pause, populate, publishReplicationEvent, publishReplicationEvent, publishReplicationEventBackup, publishSyncEvent, putBackup, removeBackup, removeReplicationEvent, resume, shutdown

Methods inherited from class java.lang.Object

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

Field Detail

connectionManager

protected WanConnectionManager connectionManager

Constructor Detail

AbstractWanReplication

public AbstractWanReplication()

Method Detail

init

public void init(com.hazelcast.instance.Node node,
                 com.hazelcast.config.WanReplicationConfig wanReplicationConfig,
                 com.hazelcast.config.WanPublisherConfig publisherConfig)

Description copied from interface: WanReplicationEndpoint

Initializes the endpoint using the given arguments.

Specified by:

init in interface WanReplicationEndpoint

Overrides:

init in class AbstractWanPublisher

Parameters:

node - the current node that tries to connect

wanReplicationConfig - WanReplicationConfig config

publisherConfig - this endpoint will be initialized using this WanPublisherConfig instance

isConnected

public boolean isConnected()

Description copied from class: AbstractWanPublisher

Tests is there is at least one alive connection to a configured target cluster member over WAN.

Specified by:

isConnected in class AbstractWanPublisher

Returns:

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

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

afterShutdown

protected void afterShutdown()

Overrides:

afterShutdown in class AbstractWanPublisher