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, com.hazelcast.spi.LiveOperationsTracker

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. NOTE The WAN batch collection mechanism needs to be run by one thread only for a single publisher.

Field Summary

Fields

Modifier and Type	Field and Description
static String	WAN_BATCH_SENDER_CLASS JVM argument for changing the implementation of the base implementation for the WanBatchSender.
static String	WAN_EXECUTOR Executor name for WAN replication tasks, e.g.

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, state, syncSupport, wanCounter, wanPublisherId, wanReplicationName

Constructor Summary

Constructors

Constructor and Description
WanBatchReplication()

Method Summary

Modifier and Type	Method and Description
protected WanPublisherSyncSupport	createWanSyncSupport() Creates the instance implementing WAN sync features.
long	getFailedTransmissionCount() Returns the number of failed WAN batch transmissions.
BatchReplicationStrategy	getReplicationStrategy()
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	populate(com.hazelcast.spi.LiveOperations liveOperations)
void	publishAntiEntropyEvent(WanAntiEntropyEvent event) Publishes an anti-entropy event.
void	run()

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

afterShutdown, 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, publishReplicationEvent, publishReplicationEvent, publishReplicationEventBackup, publishSyncEvent, putBackup, removeBackup, removeBackups, removeReplicationEvent, reset, resume, shutdown, stop

Methods inherited from class java.lang.Object

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

Field Detail

WAN_BATCH_SENDER_CLASS

public static final String WAN_BATCH_SENDER_CLASS

JVM argument for changing the implementation of the base implementation for the WanBatchSender. Intended for testing and benchmarking, e.g. where the target cluster can be mocked by generating responses after a configurable latency.

See Also:

Constant Field Values

WAN_EXECUTOR

public static final String WAN_EXECUTOR

Executor name for WAN replication tasks, e.g. collecting batches and sending them to target cluster, handling responses, performing WAN sync and merkle tree comparisons, etc. The default will use the cached executor but users can define a concrete executor if WAN replication requires separate threads.

See Also:

Constant Field Values

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

run

public void run()

This method mustn't run concurrently.

Specified by:

run in interface Runnable

createWanSyncSupport

protected WanPublisherSyncSupport createWanSyncSupport()

Description copied from class: AbstractWanPublisher

Creates the instance implementing WAN sync features. This method must not return null.

Specified by:

createWanSyncSupport in class AbstractWanPublisher

publishAntiEntropyEvent

public void publishAntiEntropyEvent(WanAntiEntropyEvent event)

Publishes an anti-entropy event. This method does not wait for the event processing to complete.

Specified by:

publishAntiEntropyEvent in class AbstractWanPublisher

Parameters:

event - the WAN anti-entropy event

populate

public void populate(com.hazelcast.spi.LiveOperations liveOperations)

Specified by:

populate in interface com.hazelcast.spi.LiveOperationsTracker

getFailedTransmissionCount

public long getFailedTransmissionCount()

Returns the number of failed WAN batch transmissions.

getReplicationStrategy

public BatchReplicationStrategy getReplicationStrategy()