com.hazelcast.enterprise.wan.replication

Class DefaultWanBatchSender

java.lang.Object

com.hazelcast.enterprise.wan.replication.DefaultWanBatchSender

All Implemented Interfaces:

WanBatchSender

public class DefaultWanBatchSender
extends Object
implements WanBatchSender

The default implementation of the WanBatchSender. It will send the WAN batch as a WanOperation to the target address and block for a configurable amount of time. It will also remove a connection if there was an exception while sending the operation.

Constructor Summary

Constructors

Constructor and Description
DefaultWanBatchSender()

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

DefaultWanBatchSender

public DefaultWanBatchSender()

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