com.hazelcast.enterprise.wan

Interface WanEventQueueMigrationListener

All Known Implementing Classes:

AbstractWanPublisher, AbstractWanReplication, WanBatchReplication

public interface WanEventQueueMigrationListener

Interface for WAN queue migration related events. Can be implemented by WAN endpoints to listen to WAN queue migration events, for example to maintain the WAN event counters.

None of the methods of this interface is expected to block or fail.

See Also:

PartitionMigrationEvent, MigrationAwareService

Method Summary

Modifier and Type	Method and Description
void	onMigrationCommit(int partitionId, int currentReplicaIndex, int newReplicaIndex) Indicates that migration is committing for a given partition
void	onMigrationRollback(int partitionId, int currentReplicaIndex, int newReplicaIndex) Indicates that migration is rolling back for a given partition
void	onMigrationStart(int partitionId, int currentReplicaIndex, int newReplicaIndex) Indicates that migration started for a given partition
void	onWanQueueClearedDuringMigration(int partitionId, int currentReplicaIndex, int clearedQueueDepth) Indicates that a partition's WAN event queue is cleared during migration

Method Detail

onMigrationStart

void onMigrationStart(int partitionId,
                      int currentReplicaIndex,
                      int newReplicaIndex)

Indicates that migration started for a given partition

Parameters:

partitionId - the partition being migrated

currentReplicaIndex - the current replica index of the partition

newReplicaIndex - the new replica index if the partition

onMigrationCommit

void onMigrationCommit(int partitionId,
                       int currentReplicaIndex,
                       int newReplicaIndex)

Indicates that migration is committing for a given partition

Parameters:

partitionId - the partition being migrated

currentReplicaIndex - the current replica index of the partition

newReplicaIndex - the new replica index if the partition

onMigrationRollback

void onMigrationRollback(int partitionId,
                         int currentReplicaIndex,
                         int newReplicaIndex)

Indicates that migration is rolling back for a given partition

Parameters:

partitionId - the partition being migrated

currentReplicaIndex - the current replica index of the partition

newReplicaIndex - the new replica index if the partition

onWanQueueClearedDuringMigration

void onWanQueueClearedDuringMigration(int partitionId,
                                      int currentReplicaIndex,
                                      int clearedQueueDepth)

Indicates that a partition's WAN event queue is cleared during migration

Parameters:

partitionId - the partition being migrated

currentReplicaIndex - the current replica index of the partition

clearedQueueDepth - the depth of the migrated WAN queue