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)

Method Summary

Modifier and Type	Method and Description
boolean	send(BatchWanReplicationEvent batchReplicationEvent, com.hazelcast.nio.Address target) Sends the WAN batch to the target address

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)

Method Detail

send

public boolean send(BatchWanReplicationEvent batchReplicationEvent,
                    com.hazelcast.nio.Address target)

Description copied from interface: WanBatchSender

Sends the WAN batch to the target address

Specified by:

send in interface WanBatchSender

Parameters:

batchReplicationEvent - the WAN batch events

target - the target address

Returns:

true if the batch was sent successfully