Package org.nuxeo.ecm.core.event.impl

Class AsyncEventExecutor

java.lang.Object

org.nuxeo.ecm.core.event.impl.AsyncEventExecutor

public class AsyncEventExecutor
extends Object

Executor of async listeners passing them to the WorkManager.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AsyncEventExecutor.ListenerWork

Constructor Summary

Constructors

Constructor	Description
AsyncEventExecutor()

Method Summary

Modifier and Type	Method	Description
int	getActiveCount()
int	getUnfinishedCount()
WorkManager	getWorkManager()
void	init()
void	run(List<EventListenerDescriptor> listeners, EventBundle bundle)
boolean	shutdown(long timeoutMillis)
boolean	waitForCompletion(long timeoutMillis)

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncEventExecutor

public AsyncEventExecutor()

Method Details

getWorkManager

public WorkManager getWorkManager()

init

public void init()

shutdown

public boolean shutdown(long timeoutMillis)
                 throws InterruptedException

Throws:

InterruptedException

waitForCompletion

public boolean waitForCompletion(long timeoutMillis)
                          throws InterruptedException

Throws:

InterruptedException

run

public void run(List<EventListenerDescriptor> listeners,
 EventBundle bundle)

getUnfinishedCount

public int getUnfinishedCount()

getActiveCount

public int getActiveCount()