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:

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, paused, queueCapacity, queueFullBehavior, queueLoggerTimePeriodMs, running, stagingQueue, syncManager, syncRequests, targetGroupName, wanReplicationName

Constructor Summary

Constructors

Constructor and Description
WanBatchReplication()

Method Summary

Modifier and Type	Method and Description
protected void	afterShutdown()
long	getFailedTransmissionCount() Returns the number of failed WAN batch transmissions.
int	getStagingQueueSize()
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, decrementWANQueueSize, getCurrentBackupElementCount, getCurrentElementCount, getPartitionId, getPublisherQueueContainer, 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

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 - WanReplicationConfig config

wanPublisherConfig - this endpoint will be initialized using this WanPublisherConfig instance

afterShutdown

protected void afterShutdown()

Overrides:

afterShutdown in class AbstractWanReplication

getStagingQueueSize

public int getStagingQueueSize()

Overrides:

getStagingQueueSize in class AbstractWanPublisher

run

public void run()

Specified by:

run in interface Runnable

getFailedTransmissionCount

public long getFailedTransmissionCount()

Returns the number of failed WAN batch transmissions.