org.nuxeo.ecm.core.event.impl

Class PostCommitEventExecutor

java.lang.Object

org.nuxeo.ecm.core.event.impl.PostCommitEventExecutor

public class PostCommitEventExecutor
extends Object

Executor that passes an event bundle to post-commit asynchronous listeners (in a separated thread in order to manage transactions).

Allows a bulk mode where transaction management is not per-listener done once for the whole set of listeners.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	PostCommitEventExecutor.EventBundleBulkRunner Lets the listeners process the event bundle in bulk mode.
protected static class	PostCommitEventExecutor.EventBundleRunner Lets the listeners process the event bundle.

Field Summary

Fields

Modifier and Type	Field and Description
static String	BULK_TIMEOUT_PROP
static String	DEFAULT_BULK_TIMEOUT_S
static int	DEFAULT_TIMEOUT_MS
static int	DEFAULT_TIMEOUT_TEST_MS
protected ExecutorService	executor
static String	TIMEOUT_MS_PROP

Constructor Summary

Constructors

Constructor and Description
PostCommitEventExecutor()

Method Summary

Modifier and Type	Method and Description
protected int	getDefaultTimeoutMs()
void	run(List<EventListenerDescriptor> listeners, EventBundle event)
void	run(List<EventListenerDescriptor> listeners, EventBundle bundle, long timeoutMillis, boolean bulk)
void	runBulk(List<EventListenerDescriptor> listeners, EventBundle event)
void	shutdown(long timeoutMillis)

Methods inherited from class java.lang.Object

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

Field Detail

TIMEOUT_MS_PROP

public static final String TIMEOUT_MS_PROP

See Also:

Constant Field Values

DEFAULT_TIMEOUT_MS

public static final int DEFAULT_TIMEOUT_MS

See Also:

Constant Field Values

DEFAULT_TIMEOUT_TEST_MS

public static final int DEFAULT_TIMEOUT_TEST_MS

See Also:

Constant Field Values

DEFAULT_BULK_TIMEOUT_S

public static final String DEFAULT_BULK_TIMEOUT_S

See Also:

Constant Field Values

BULK_TIMEOUT_PROP

public static final String BULK_TIMEOUT_PROP

See Also:

Constant Field Values

executor

protected final ExecutorService executor

Constructor Detail

PostCommitEventExecutor

public PostCommitEventExecutor()

Method Detail

getDefaultTimeoutMs

protected int getDefaultTimeoutMs()

shutdown

public void shutdown(long timeoutMillis)
              throws InterruptedException

Throws:

InterruptedException

run

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

runBulk

public void runBulk(List<EventListenerDescriptor> listeners,
                    EventBundle event)

run

public void run(List<EventListenerDescriptor> listeners,
                EventBundle bundle,
                long timeoutMillis,
                boolean bulk)