com.hazelcast.enterprise.wan.replication

Class WanBatchReplication

java.lang.Object

com.hazelcast.enterprise.wan.replication.AbstractWanPublisher

com.hazelcast.enterprise.wan.replication.AbstractWanReplication

com.hazelcast.enterprise.wan.replication.WanBatchReplication

All Implemented Interfaces:

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

public class WanBatchReplication
extends AbstractWanReplication
implements Runnable

WAN replication publisher that sends events in batches. Basically, it publishes events either when enough events are enqueued or enqueued events have waited for enough time.

The event count is configurable by WanReplicationProperties.BATCH_SIZE and is by default. The elapsed time is configurable by WanReplicationProperties.BATCH_MAX_DELAY_MILLIS and is by default. The events are sent to the endpoints depending on the event key partition.

Field Summary

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

connectionManager

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

configurationContext, eventQueueContainer, lastQueueFullLogTimeMs, localGroupName, logger, node, queueCapacity, queueFullBehavior, queueLoggerTimePeriodMs, running, stagingQueue, state, wanCounter, wanPublisherId, wanReplicationName

Constructor Summary

Constructors

Constructor and Description
WanBatchReplication()

Method Summary

Modifier and Type	Method and Description
protected void	afterShutdown()
protected WanPublisherSyncSupport	createWanSyncSupport() Creates a support instance for processing WAN merkle tree anti-entropy events.
long	getFailedTransmissionCount() Returns the number of failed WAN batch transmissions.
int	getStagingQueueSize() Returns the capacity of the WAN staging queue.
void	init(com.hazelcast.instance.Node node, com.hazelcast.config.WanReplicationConfig wanReplicationConfig, com.hazelcast.config.WanPublisherConfig wanPublisherConfig) Initializes the endpoint using the given arguments.
void	run()

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

getTargetEndpoints, isConnected

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

addCacheQueue, addMapQueue, checkWanReplicationQueues, clearQueues, collectAllServiceNamespaces, collectReplicationData, decrementCounter, destroyMapData, getCurrentBackupElementCount, getCurrentElementCount, getPartitionId, getPublisherQueueContainer, getStats, onMigrationCommit, onMigrationRollback, onMigrationStart, onWanQueueClearedDuringMigration, pause, populate, publishAntiEntropyEvent, publishReplicationEvent, publishReplicationEvent, publishReplicationEventBackup, publishSyncEvent, putBackup, removeBackup, removeReplicationEvent, reset, resume, shutdown, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

WanBatchReplication

public WanBatchReplication()

Method Detail

init

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

Description copied from interface: WanReplicationEndpoint

Initializes the endpoint using the given arguments.

Specified by:

init in interface WanReplicationEndpoint

Overrides:

init in class AbstractWanReplication

Parameters:

node - the current node that tries to connect

wanReplicationConfig - the replication config

wanPublisherConfig - this endpoint will be initialized using this WanPublisherConfig instance

afterShutdown

protected void afterShutdown()

Overrides:

afterShutdown in class AbstractWanReplication

getStagingQueueSize

public int getStagingQueueSize()

Description copied from class: AbstractWanPublisher

Returns the capacity of the WAN staging queue. The staging queue is a queue for multiplexed map/cache partition WAN events that are about to be transmitted to the target cluster.

Overrides:

getStagingQueueSize in class AbstractWanPublisher

See Also:

AbstractWanPublisher.stagingQueue

run

public void run()

Specified by:

run in interface Runnable

createWanSyncSupport

protected WanPublisherSyncSupport createWanSyncSupport()

Description copied from class: AbstractWanPublisher

Creates a support instance for processing WAN merkle tree anti-entropy events. This method may return null if merkle tree WAN sync is not supported.

Overrides:

createWanSyncSupport in class AbstractWanPublisher

getFailedTransmissionCount

public long getFailedTransmissionCount()

Returns the number of failed WAN batch transmissions.