@ThreadSafe public final class RepositoryChangeBus extends Object implements ChangeBus
ChangeBus
implementation.Modifier and Type | Field and Description |
---|---|
protected static Logger |
LOGGER |
protected boolean |
shutdown |
Constructor and Description |
---|
RepositoryChangeBus(ExecutorService executor,
String systemWorkspaceName)
Creates new change bus
|
Modifier and Type | Method and Description |
---|---|
boolean |
hasObservers()
Checks if there are any observers registered with the bus.
|
void |
notify(ChangeSet changeSet)
Notifies a listener of the given changes.
|
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.
|
protected static final Logger LOGGER
protected volatile boolean shutdown
public RepositoryChangeBus(ExecutorService executor, String systemWorkspaceName)
executor
- the ExecutorService
which will be used internally to submit workers to dispatching events to
listeners.systemWorkspaceName
- the name of the system workspace, needed because internal (system) events are dispatched in the
same thread; may no be nullpublic void start()
ChangeBus
public void shutdown()
ChangeBus
ChangeBus.start()
public boolean register(ChangeSetListener listener)
Observable
register
in interface Observable
listener
- the observer to be added; may be nullpublic boolean unregister(ChangeSetListener listener)
Observable
unregister
in interface Observable
listener
- the observer to be removed; may not be nullpublic void notify(ChangeSet changeSet)
ChangeSetListener
notify
in interface ChangeSetListener
changeSet
- a non-null
ChangeSet
public boolean hasObservers()
ChangeBus
hasObservers
in interface ChangeBus
true
if there are any registered observers, false
otherwiseCopyright © 2008-2014 JBoss, a division of Red Hat. All Rights Reserved.