org.nuxeo.ecm.core.event.impl

Class EventServiceImpl

java.lang.Object

org.nuxeo.ecm.core.event.impl.EventServiceImpl

All Implemented Interfaces:

Synchronization, EventProducer, EventService, EventServiceAdmin

public class EventServiceImpl
extends Object
implements EventService, EventServiceAdmin, Synchronization

Implementation of the event service.

Field Summary

Fields

Modifier and Type	Field and Description
static VMID	VMID

Constructor Summary

Constructors

Constructor and Description
EventServiceImpl()

Method Summary

Methods

Modifier and Type	Method and Description
void	addEventListener(EventListenerDescriptor listener) Adds a new event listener.
void	afterCompletion(int status)
void	beforeCompletion()
void	fireEvent(Event event) Fires an event.
void	fireEvent(String name, EventContext context) Fires an event given its name and a context.
void	fireEventBundle(EventBundle event) Fires all recorded events in a transaction.
void	fireEventBundleSync(EventBundle event) Fires an event bundle in synchronous mode.
int	getActiveAsyncTaskCount() Deprecated. use waitForAsyncCompletion() instead.
int	getActiveThreadsCount()
EventListenerDescriptor	getEventListener(String name) Gets the event listener descriptor corresponding to the give name.
EventListenerList	getEventListenerList()
List<EventListener>	getEventListeners() Gets the list of the registered event listeners.
int	getEventsInQueueCount()
EventListenerList	getListenerList()
List<PostCommitEventListener>	getPostCommitEventListeners() Get the list of the registered post commit event listeners.
void	init()
boolean	isBlockAsyncHandlers()
boolean	isBlockSyncPostCommitHandlers()
boolean	isBulkModeEnabled()
void	registerForAsyncWait(AsyncWaitHook callback)
void	removeEventListener(EventListenerDescriptor listener) Removes an event listener.
void	setBlockAsyncHandlers(boolean blockAsyncHandlers)
void	setBlockSyncPostCommitHandlers(boolean blockSyncPostComitHandlers)
void	setBulkModeEnabled(boolean bulkModeEnabled)
void	setListenerEnabledFlag(String listenerName, boolean enabled)
void	shutdown(long timeoutMillis)
void	unregisterForAsyncWait(AsyncWaitHook callback)
void	waitForAsyncCompletion() Waits until all asynchronous tasks are finished.
void	waitForAsyncCompletion(long timeout) Waits until all asynchronous tasks are finished, but waits no longer than the given number of milliseconds.

Methods inherited from class java.lang.Object

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

Field Detail

VMID

public static final VMID VMID

Constructor Detail

EventServiceImpl

public EventServiceImpl()

Method Detail

init

public void init()

shutdown

public void shutdown(long timeoutMillis)
              throws InterruptedException

Throws:

InterruptedException

registerForAsyncWait

public void registerForAsyncWait(AsyncWaitHook callback)

unregisterForAsyncWait

public void unregisterForAsyncWait(AsyncWaitHook callback)

getActiveAsyncTaskCount

@Deprecated
public int getActiveAsyncTaskCount()

Deprecated. use waitForAsyncCompletion() instead.

waitForAsyncCompletion

public void waitForAsyncCompletion()

Description copied from interface: EventService

Waits until all asynchronous tasks are finished.

Specified by:

waitForAsyncCompletion in interface EventService

waitForAsyncCompletion

public void waitForAsyncCompletion(long timeout)

Description copied from interface: EventService

Waits until all asynchronous tasks are finished, but waits no longer than the given number of milliseconds.

Specified by:

waitForAsyncCompletion in interface EventService

Parameters:

timeout - the maximum time to wait for, in milliseconds

addEventListener

public void addEventListener(EventListenerDescriptor listener)

Description copied from interface: EventService

Adds a new event listener. Used by the framework.

The event listener is described by a EventListenerDescriptor that may specify a priority. Both types of listeners (immediate and post-commit) are registered.

Specified by:

addEventListener in interface EventService

Parameters:

listener - the listener to add

removeEventListener

public void removeEventListener(EventListenerDescriptor listener)

Description copied from interface: EventService

Removes an event listener. Used by the framework.

Specified by:

removeEventListener in interface EventService

Parameters:

listener - the listener to remove

fireEvent

public void fireEvent(String name,
             EventContext context)
               throws ClientException

Description copied from interface: EventService

Fires an event given its name and a context.

Specified by:

fireEvent in interface EventService

Parameters:

name - the event name

context - the event context

Throws:

ClientException

fireEvent

public void fireEvent(Event event)
               throws ClientException

Description copied from interface: EventService

Fires an event.

If a transaction was started, the event is registered if needed to be sent after the transaction commit.

Specified by:

fireEvent in interface EventProducer

Specified by:

fireEvent in interface EventService

Parameters:

event - the event to fire

Throws:

ClientException

fireEventBundle

public void fireEventBundle(EventBundle event)
                     throws ClientException

Description copied from interface: EventService

Fires all recorded events in a transaction. Used by the framework.

The events are fired to PostCommitEventListener listeners. Events are fired in the form of an event bundle.

Specified by:

fireEventBundle in interface EventProducer

Specified by:

fireEventBundle in interface EventService

Parameters:

event - the event bundle

Throws:

ClientException

fireEventBundleSync

public void fireEventBundleSync(EventBundle event)
                         throws ClientException

Description copied from interface: EventService

Fires an event bundle in synchronous mode. Used by the framework.

This means that asynchronous listeners will be run synchronously.

Specified by:

fireEventBundleSync in interface EventService

Throws:

ClientException

getEventListeners

public List<EventListener> getEventListeners()

Description copied from interface: EventService

Gets the list of the registered event listeners.

Modification on this list will not modify the internal lists in this EventService.

Specified by:

getEventListeners in interface EventService

Returns:

the event listeners

getPostCommitEventListeners

public List<PostCommitEventListener> getPostCommitEventListeners()

Description copied from interface: EventService

Get the list of the registered post commit event listeners.

Modification on this list will not modify the internal lists in this EventService.

Specified by:

getPostCommitEventListeners in interface EventService

Returns:

the post commit event listeners

getEventListenerList

public EventListenerList getEventListenerList()

getEventListener

public EventListenerDescriptor getEventListener(String name)

Description copied from interface: EventService

Gets the event listener descriptor corresponding to the give name.

Specified by:

getEventListener in interface EventService

Parameters:

name - the event listener name

Returns:

the descriptor, or null if not found

getListenerList

public EventListenerList getListenerList()

Specified by:

getListenerList in interface EventServiceAdmin

setListenerEnabledFlag

public void setListenerEnabledFlag(String listenerName,
                          boolean enabled)

Specified by:

setListenerEnabledFlag in interface EventServiceAdmin

getActiveThreadsCount

public int getActiveThreadsCount()

Specified by:

getActiveThreadsCount in interface EventServiceAdmin

getEventsInQueueCount

public int getEventsInQueueCount()

Specified by:

getEventsInQueueCount in interface EventServiceAdmin

isBlockAsyncHandlers

public boolean isBlockAsyncHandlers()

Specified by:

isBlockAsyncHandlers in interface EventServiceAdmin

isBlockSyncPostCommitHandlers

public boolean isBlockSyncPostCommitHandlers()

Specified by:

isBlockSyncPostCommitHandlers in interface EventServiceAdmin

setBlockAsyncHandlers

public void setBlockAsyncHandlers(boolean blockAsyncHandlers)

Specified by:

setBlockAsyncHandlers in interface EventServiceAdmin

setBlockSyncPostCommitHandlers

public void setBlockSyncPostCommitHandlers(boolean blockSyncPostComitHandlers)

Specified by:

setBlockSyncPostCommitHandlers in interface EventServiceAdmin

isBulkModeEnabled

public boolean isBulkModeEnabled()

Specified by:

isBulkModeEnabled in interface EventServiceAdmin

setBulkModeEnabled

public void setBulkModeEnabled(boolean bulkModeEnabled)

Specified by:

setBulkModeEnabled in interface EventServiceAdmin

beforeCompletion

public void beforeCompletion()

Specified by:

beforeCompletion in interface Synchronization

afterCompletion

public void afterCompletion(int status)

Specified by:

afterCompletion in interface Synchronization