org.apache.jackrabbit.oak.spi.commit

Class BackgroundObserver

java.lang.Object

org.apache.jackrabbit.oak.spi.commit.BackgroundObserver

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Observer

public class BackgroundObserver
extends java.lang.Object
implements Observer, java.io.Closeable

An observer that uses a change queue and a background thread to forward content changes to another observer. The mechanism is designed so that the contentChanged(NodeState, CommitInfo) method will never block, regardless of the behavior of the other observer. If that observer blocks or is too slow to consume all content changes, causing the change queue to fill up, any further update will automatically be merged into just one external content change, causing potential loss of local commit information. To help prevent such cases, any sequential external content changes that the background observer thread has yet to process are optionally (see alwaysCollapseExternalEvents and oak.observation.alwaysCollapseExternal) automatically merged to just one change.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_QUEUE_SIZE

Constructor Summary

Constructors

Constructor and Description
BackgroundObserver(Observer observer, java.util.concurrent.Executor executor)
BackgroundObserver(Observer observer, java.util.concurrent.Executor executor, int queueLength)
BackgroundObserver(Observer observer, java.util.concurrent.Executor executor, int queueLength, java.lang.Thread.UncaughtExceptionHandler exceptionHandler)

Method Summary

Modifier and Type	Method and Description
void	close() Clears the change queue and signals the background thread to stop without making any further contentChanged(NodeState, CommitInfo) calls to the background observer.
void	contentChanged(NodeState root, CommitInfo info) Observes a content change.
int	getMaxQueueLength()
BackgroundObserverMBean	getMBean()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_QUEUE_SIZE

public static final int DEFAULT_QUEUE_SIZE

See Also:

Constant Field Values

Constructor Detail

BackgroundObserver

public BackgroundObserver(Observer observer,
                          java.util.concurrent.Executor executor,
                          int queueLength,
                          java.lang.Thread.UncaughtExceptionHandler exceptionHandler)

BackgroundObserver

public BackgroundObserver(Observer observer,
                          java.util.concurrent.Executor executor,
                          int queueLength)

BackgroundObserver

public BackgroundObserver(Observer observer,
                          java.util.concurrent.Executor executor)

Method Detail

getMaxQueueLength

public int getMaxQueueLength()

Returns:

The max queue length used for this observer's queue

close

public void close()

Clears the change queue and signals the background thread to stop without making any further contentChanged(NodeState, CommitInfo) calls to the background observer. If the thread is currently in the middle of such a call, then that call is allowed to complete; i.e. the thread is not forcibly interrupted. This method returns immediately without blocking to wait for the thread to finish.

After a call to this method further calls to contentChanged(NodeState, CommitInfo) will throw a IllegalStateException.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

getMBean

public BackgroundObserverMBean getMBean()

contentChanged

public void contentChanged(NodeState root,
                           CommitInfo info)

Description copied from interface: Observer

Observes a content change. See the Observer class javadocs and relevant repository and observer registration details for more information on when and how this method gets called.

Specified by:

contentChanged in interface Observer

Parameters:

root - root state of the repository

info - commit information

Throws:

java.lang.IllegalStateException - if close() has already been called.