com.hazelcast.enterprise.wan.replication

Class SerialBatchReplicationStrategy

java.lang.Object

com.hazelcast.enterprise.wan.replication.SerialBatchReplicationStrategy

All Implemented Interfaces:

BatchReplicationStrategy

public class SerialBatchReplicationStrategy
extends Object
implements BatchReplicationStrategy

WAN replication strategy which will send events for a single partition ID only to a single, dedicated target endpoint if the endpoint list is not changing. This will, if there are no changes in the target endpoint list, ensure ordering of partition events.

Constructor Summary

Constructors

Constructor and Description
SerialBatchReplicationStrategy()

Method Summary

Modifier and Type	Method and Description
void	complete(com.hazelcast.nio.Address endpoint) Releases the provided target endpoint as available for sending the next event batch.
int	getFirstPartitionId(com.hazelcast.nio.Address endpoint, List<com.hazelcast.nio.Address> endpoints) Returns the first partition ID of the events which should be sent to the provided target endpoint.
com.hazelcast.nio.Address	getNextEventBatchEndpoint(List<com.hazelcast.nio.Address> endpoints) Returns the next available target endpoint from a provided list of available target endpoints.
int	getPartitionIdStep(com.hazelcast.nio.Address endpoint, List<com.hazelcast.nio.Address> endpoints) Returns the step between partition IDs of events which should be sent to the provided target endpoint.
boolean	hasOngoingReplication() Returns true if there is an ongoing replication process.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SerialBatchReplicationStrategy

public SerialBatchReplicationStrategy()

Method Detail

getNextEventBatchEndpoint

public com.hazelcast.nio.Address getNextEventBatchEndpoint(List<com.hazelcast.nio.Address> endpoints)

Description copied from interface: BatchReplicationStrategy

Returns the next available target endpoint from a provided list of available target endpoints. This method may acquire (reserve) the returned endpoint. It is the responsibility of the user of this strategy to call the BatchReplicationStrategy.complete(Address) method with the returned address to mark the endpoint as available again.

Specified by:

getNextEventBatchEndpoint in interface BatchReplicationStrategy

Parameters:

endpoints - the available target endpoints

Returns:

the next available endpoint to which an event batch can be sent

complete

public void complete(com.hazelcast.nio.Address endpoint)

Description copied from interface: BatchReplicationStrategy

Releases the provided target endpoint as available for sending the next event batch.

Specified by:

complete in interface BatchReplicationStrategy

Parameters:

endpoint - the endpoint to release

getFirstPartitionId

public int getFirstPartitionId(com.hazelcast.nio.Address endpoint,
                               List<com.hazelcast.nio.Address> endpoints)

Description copied from interface: BatchReplicationStrategy

Returns the first partition ID of the events which should be sent to the provided target endpoint.

Specified by:

getFirstPartitionId in interface BatchReplicationStrategy

Parameters:

endpoint - the target endpoint

endpoints - the list of available target endpoints

Returns:

the first partition ID of the events for which the target endpoint is responsible for

getPartitionIdStep

public int getPartitionIdStep(com.hazelcast.nio.Address endpoint,
                              List<com.hazelcast.nio.Address> endpoints)

Description copied from interface: BatchReplicationStrategy

Returns the step between partition IDs of events which should be sent to the provided target endpoint.

Specified by:

getPartitionIdStep in interface BatchReplicationStrategy

Parameters:

endpoint - the target endpoint

endpoints - the list of available target endpoints

Returns:

the step between partition IDs of the events which should be sent to the target endpoint

hasOngoingReplication

public boolean hasOngoingReplication()

Description copied from interface: BatchReplicationStrategy

Returns true if there is an ongoing replication process.

Specified by:

hasOngoingReplication in interface BatchReplicationStrategy

toString

public String toString()

Overrides:

toString in class Object