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

Class PostCommitEventExecutor.EventBundleBulkRunner

java.lang.Object

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

All Implemented Interfaces:

Callable<Boolean>

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 final EventBundle	bundle
protected final String	callerThread
protected final List<EventListenerDescriptor>	listeners
protected final byte[]	traceContext

Constructor Summary

Constructors

Constructor	Description
EventBundleBulkRunner(List<EventListenerDescriptor> listeners, EventBundle bundle)

Method Summary

Modifier and Type	Method	Description
Boolean	call()
protected io.opencensus.trace.Span	getTracingSpan(String spanName)

Methods inherited from class java.lang.Object

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

Field Details

listeners

protected final List<EventListenerDescriptor> listeners

bundle

protected final EventBundle bundle

callerThread

protected final String callerThread

traceContext

protected final byte[] traceContext

Constructor Details

EventBundleBulkRunner

public EventBundleBulkRunner(List<EventListenerDescriptor> listeners,
 EventBundle bundle)

Method Details

call

public Boolean call()

Specified by:

call in interface Callable<Boolean>

getTracingSpan

protected io.opencensus.trace.Span getTracingSpan(String spanName)