org.modeshape.jcr.bus

Class RepositoryCursor

java.lang.Object

org.modeshape.common.collection.ring.SingleProducerCursor

org.modeshape.jcr.bus.RepositoryCursor

All Implemented Interfaces:

Cursor, DependentOnPointers

public final class RepositoryCursor
extends SingleProducerCursor

An extension to the SingleProducerCursor cursor which adds some functionality required by the repository.

Field Summary

Fields inherited from class org.modeshape.common.collection.ring.SingleProducerCursor

current, finalPosition, stayBehinds, waitStrategy

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RepositoryCursor(int bufferSize, WaitStrategy waitStrategy, RepositoryStatistics statistics)

Method Summary

Modifier and Type	Method and Description
boolean	publish(long position) Publish the supplied position, making it available for consumers.

Methods inherited from class org.modeshape.common.collection.ring.SingleProducerCursor

claim, claim, claimUpTo, complete, createGarbageCollectingConsumer, getBufferSize, getCurrent, getHighestPublishedPosition, ignore, isComplete, newBarrier, newPointer, positionOfSlowestConsumer, positionOfSlowestPointer, signalConsumers, stayBehind

Methods inherited from class java.lang.Object

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

Constructor Detail

RepositoryCursor

protected RepositoryCursor(int bufferSize,
                           WaitStrategy waitStrategy,
                           RepositoryStatistics statistics)

Method Detail

publish

public boolean publish(long position)

Description copied from interface: Cursor

Publish the supplied position, making it available for consumers.

Specified by:

publish in interface Cursor

Overrides:

publish in class SingleProducerCursor

Parameters:

position - the position that is now available for consumers

Returns:

true if the position was published, or false if not