com.hazelcast.internal.partition.impl

Class InternalMigrationListener

java.lang.Object

com.hazelcast.internal.partition.impl.InternalMigrationListener

All Implemented Interfaces:

EventListener

Direct Known Subclasses:

InternalMigrationListener.NopInternalMigrationListener

public abstract class InternalMigrationListener
extends Object
implements EventListener

Internal synchronous/blocking listener to intercept migration cycle on master member and migration participants.

It's used to execute a specific test scenario deterministically. There's no user side api or configuration.

See Also:

InternalPartitionServiceImpl.setInternalMigrationListener(InternalMigrationListener)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InternalMigrationListener.MigrationParticipant
static class	InternalMigrationListener.NopInternalMigrationListener

Constructor Summary

Constructors

Constructor and Description
InternalMigrationListener()

Method Summary

Modifier and Type	Method and Description
void	onMigrationCommit(InternalMigrationListener.MigrationParticipant participant, MigrationInfo migrationInfo)
void	onMigrationComplete(InternalMigrationListener.MigrationParticipant participant, MigrationInfo migrationInfo, boolean success)
void	onMigrationRollback(InternalMigrationListener.MigrationParticipant participant, MigrationInfo migrationInfo)
void	onMigrationStart(InternalMigrationListener.MigrationParticipant participant, MigrationInfo migrationInfo)
void	onPromotionComplete(InternalMigrationListener.MigrationParticipant participant, Collection<MigrationInfo> migrationInfos, boolean success)
void	onPromotionStart(InternalMigrationListener.MigrationParticipant participant, Collection<MigrationInfo> migrationInfos)

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalMigrationListener

public InternalMigrationListener()

Method Detail

onMigrationStart

public void onMigrationStart(InternalMigrationListener.MigrationParticipant participant,
                             MigrationInfo migrationInfo)

onMigrationComplete

public void onMigrationComplete(InternalMigrationListener.MigrationParticipant participant,
                                MigrationInfo migrationInfo,
                                boolean success)

onMigrationCommit

public void onMigrationCommit(InternalMigrationListener.MigrationParticipant participant,
                              MigrationInfo migrationInfo)

onMigrationRollback

public void onMigrationRollback(InternalMigrationListener.MigrationParticipant participant,
                                MigrationInfo migrationInfo)

onPromotionStart

public void onPromotionStart(InternalMigrationListener.MigrationParticipant participant,
                             Collection<MigrationInfo> migrationInfos)

onPromotionComplete

public void onPromotionComplete(InternalMigrationListener.MigrationParticipant participant,
                                Collection<MigrationInfo> migrationInfos,
                                boolean success)