com.hazelcast.map.impl.querycache.event.sequence

Class DefaultSubscriberSequencerProvider

java.lang.Object

com.hazelcast.map.impl.querycache.event.sequence.DefaultSubscriberSequencerProvider

All Implemented Interfaces:

SubscriberSequencerProvider

public class DefaultSubscriberSequencerProvider
extends Object
implements SubscriberSequencerProvider

This class provides on-demand PartitionSequencer implementations for subscriber side.

See Also:

PartitionSequencer

Constructor Summary

Constructors

Constructor and Description
DefaultSubscriberSequencerProvider()

Method Summary

Modifier and Type	Method and Description
boolean	compareAndSetSequence(long expect, long update, int partitionId) Atomically sets the value of sequence number for the partition.
long	getSequence(int partitionId) Returns partition's current sequence number.
void	reset(int partitionId) Resets the sequence number for the supplied partition to zero.
void	resetAll() Like SubscriberSequencerProvider.reset(int) but this method resets all partition sequences.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSubscriberSequencerProvider

public DefaultSubscriberSequencerProvider()

Method Detail

compareAndSetSequence

public boolean compareAndSetSequence(long expect,
                                     long update,
                                     int partitionId)

Description copied from interface: SubscriberSequencerProvider

Atomically sets the value of sequence number for the partition.

Specified by:

compareAndSetSequence in interface SubscriberSequencerProvider

Parameters:

expect - the expected sequence.

update - the new sequence.

partitionId - ID of the partition.

Returns:

true if Compare-and-Set operation is successful, otherwise returns false.

getSequence

public long getSequence(int partitionId)

Description copied from interface: SubscriberSequencerProvider

Returns partition's current sequence number.

Specified by:

getSequence in interface SubscriberSequencerProvider

Parameters:

partitionId - ID of the partition.

Returns:

current sequence number.

reset

public void reset(int partitionId)

Description copied from interface: SubscriberSequencerProvider

Resets the sequence number for the supplied partition to zero.

Specified by:

reset in interface SubscriberSequencerProvider

Parameters:

partitionId - ID of the partition.

resetAll

public void resetAll()

Description copied from interface: SubscriberSequencerProvider

Like SubscriberSequencerProvider.reset(int) but this method resets all partition sequences.

Specified by:

resetAll in interface SubscriberSequencerProvider