com.hazelcast.enterprise.wan.replication

Class LatencyTrackingWanBatchSender

java.lang.Object

com.hazelcast.enterprise.wan.replication.LatencyTrackingWanBatchSender

All Implemented Interfaces:

WanBatchSender

public class LatencyTrackingWanBatchSender
extends Object
implements WanBatchSender

A wrapper around a WanBatchSender implementation that additionally tracks the latency for all successful transmissions of the WAN batches.

Constructor Summary

Constructors

Constructor and Description
LatencyTrackingWanBatchSender(WanBatchSender delegate, com.hazelcast.internal.diagnostics.StoreLatencyPlugin plugin, String wanPublisherId, Executor responseExecutor)

Method Summary

Modifier and Type	Method and Description
void	init(com.hazelcast.instance.Node node, WanBatchReplication publisher) Initialises this sender.
com.hazelcast.core.ICompletableFuture<Boolean>	send(BatchWanReplicationEvent batchReplicationEvent, com.hazelcast.nio.Address target) Sends the WAN batch to the target address and returns a future representing the pending completion of the invocation.

Methods inherited from class java.lang.Object

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

Constructor Detail

LatencyTrackingWanBatchSender

public LatencyTrackingWanBatchSender(WanBatchSender delegate,
                                     com.hazelcast.internal.diagnostics.StoreLatencyPlugin plugin,
                                     String wanPublisherId,
                                     Executor responseExecutor)

Method Detail

init

public void init(com.hazelcast.instance.Node node,
                 WanBatchReplication publisher)

Description copied from interface: WanBatchSender

Initialises this sender.

Specified by:

init in interface WanBatchSender

Parameters:

node - the node on which this sender is running

publisher - the WAN publisher for which this sender is used to send batches for

send

public com.hazelcast.core.ICompletableFuture<Boolean> send(BatchWanReplicationEvent batchReplicationEvent,
                                                           com.hazelcast.nio.Address target)

Description copied from interface: WanBatchSender

Sends the WAN batch to the target address and returns a future representing the pending completion of the invocation.

Specified by:

send in interface WanBatchSender

Parameters:

batchReplicationEvent - the WAN batch events

target - the target address

Returns:

true if the batch was sent successfully