Package org.nuxeo.ecm.core.event.impl
Class PostCommitEventExecutor.EventBundleBulkRunner
- java.lang.Object
-
- org.nuxeo.ecm.core.event.impl.PostCommitEventExecutor.EventBundleBulkRunner
-
- Enclosing class:
- PostCommitEventExecutor
protected static class PostCommitEventExecutor.EventBundleBulkRunner extends Object implements Callable<Boolean>
Lets the listeners process the event bundle in bulk mode.The event bundle is reconnected to a single session and a single transaction is started for all the listeners.
In case of exception in a listener, the transaction is rolled back and processing stops.
In case of timeout, the transaction is rolled back and processing stops.
-
-
Field Summary
Fields Modifier and Type Field Description protected EventBundle
bundle
protected String
callerThread
protected List<EventListenerDescriptor>
listeners
protected byte[]
traceContext
-
Constructor Summary
Constructors Constructor Description EventBundleBulkRunner(List<EventListenerDescriptor> listeners, EventBundle bundle)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Boolean
call()
protected io.opencensus.trace.Span
getTracingSpan(String spanName)
-
-
-
Field Detail
-
listeners
protected final List<EventListenerDescriptor> listeners
-
bundle
protected final EventBundle bundle
-
callerThread
protected final String callerThread
-
traceContext
protected final byte[] traceContext
-
-
Constructor Detail
-
EventBundleBulkRunner
public EventBundleBulkRunner(List<EventListenerDescriptor> listeners, EventBundle bundle)
-
-