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(WanConnectionManager connectionManager, com.hazelcast.logging.ILogger logger, com.hazelcast.spi.serialization.SerializationService serializationService, com.hazelcast.spi.OperationService operationService, WanConfigurationContext configurationContext)

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

DefaultWanBatchSender

public DefaultWanBatchSender(WanConnectionManager connectionManager,
                             com.hazelcast.logging.ILogger logger,
                             com.hazelcast.spi.serialization.SerializationService serializationService,
                             com.hazelcast.spi.OperationService operationService,
                             WanConfigurationContext configurationContext)

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