org.modeshape.jcr.bus
Class RepositoryChangeBus

java.lang.Object
  org.modeshape.jcr.bus.RepositoryChangeBus

All Implemented Interfaces:

ChangeBus, ChangeSetListener, Observable

@ThreadSafe
public final class RepositoryChangeBus
extends Object
implements ChangeBus

A standard ChangeBus implementation.

Field Summary

protected boolean

shutdown

Constructor Summary

RepositoryChangeBus(ExecutorService executor, String systemWorkspaceName, boolean separateThreadForSystemWorkspace)

Method Summary

boolean	hasObservers() Checks if there are any observers registered with the bus.
void	notify(ChangeSet changeSet)
boolean	register(ChangeSetListener listener) Register the supplied observer.
void	shutdown() Shuts down the change bus, closing and clearing resources created during ChangeBus.start()
void	start() Starts up the change bus.
boolean	unregister(ChangeSetListener listener) Unregister the supplied observer.

Methods inherited from class java.lang.Object

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

Field Detail

shutdown

protected volatile boolean shutdown

Constructor Detail

RepositoryChangeBus

public RepositoryChangeBus(ExecutorService executor,
                           String systemWorkspaceName,
                           boolean separateThreadForSystemWorkspace)

Method Detail

start

public void start()

Description copied from interface: ChangeBus

Starts up the change bus.

Specified by:

start in interface ChangeBus

shutdown

public void shutdown()

Description copied from interface: ChangeBus

Shuts down the change bus, closing and clearing resources created during ChangeBus.start()

Specified by:

shutdown in interface ChangeBus

register

public boolean register(ChangeSetListener listener)

Description copied from interface: Observable

Register the supplied observer. This method does nothing if the observer reference is null.

Specified by:

register in interface Observable

Parameters:

listener - the observer to be added; may be null

Returns:

true if the observer was added, or false if the observer was null, if the observer was already registered, or if the observer could not be added

unregister

public boolean unregister(ChangeSetListener listener)

Description copied from interface: Observable

Unregister the supplied observer. This method does nothing if the observer reference is null.

Specified by:

unregister in interface Observable

Parameters:

listener - the observer to be removed; may not be null

Returns:

true if the observer was removed, or false if the observer was null or if the observer was not registered on this source

notify

public void notify(ChangeSet changeSet)

Specified by:

notify in interface ChangeSetListener

hasObservers

public boolean hasObservers()

Description copied from interface: ChangeBus

Checks if there are any observers registered with the bus.

Specified by:

hasObservers in interface ChangeBus

Returns:

true if there are any registered observers, false otherwise