com.hazelcast.enterprise.wan.replication

Interface WanBatchSender

All Known Implementing Classes:

DefaultWanBatchSender, LatencyTrackingWanBatchSender

public interface WanBatchSender

The WanBatchSender is responsible for transmitting the WAN event batch from this node to a target address (on the target cluster).

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.

Method Detail

init

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

Initialises this sender.

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

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.

Parameters:

batchReplicationEvent - the WAN batch events

target - the target address

Returns:

true if the batch was sent successfully