Package org.nuxeo.ecm.core.event.impl
Class PostCommitEventExecutor
java.lang.Object
org.nuxeo.ecm.core.event.impl.PostCommitEventExecutor
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
Modifier and TypeClassDescriptionprotected static class
Lets the listeners process the event bundle in bulk mode.protected static class
Lets the listeners process the event bundle. -
Field Summary
Modifier and TypeFieldDescriptionstatic final String
static final String
static final int
static final int
protected final ExecutorService
static final String
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected int
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)
-
Field Details
-
TIMEOUT_MS_PROP
- See Also:
-
DEFAULT_TIMEOUT_MS
public static final int DEFAULT_TIMEOUT_MS- See Also:
-
DEFAULT_TIMEOUT_TEST_MS
public static final int DEFAULT_TIMEOUT_TEST_MS- See Also:
-
DEFAULT_BULK_TIMEOUT_S
- See Also:
-
BULK_TIMEOUT_PROP
- See Also:
-
executor
-
-
Constructor Details
-
PostCommitEventExecutor
public PostCommitEventExecutor()
-
-
Method Details
-
getDefaultTimeoutMs
protected int getDefaultTimeoutMs() -
shutdown
- Throws:
InterruptedException
-
run
-
runBulk
-
run
public void run(List<EventListenerDescriptor> listeners, EventBundle bundle, long timeoutMillis, boolean bulk)
-