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

Class PostCommitEventExecutor.EventBundleRunner

java.lang.Object

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

All Implemented Interfaces:

Callable<Boolean>

Enclosing class:

PostCommitEventExecutor

protected static class PostCommitEventExecutor.EventBundleRunner
extends Object
implements Callable<Boolean>

Lets the listeners process the event bundle.

For each listener, the event bundle is reconnected to a session and a transaction is started.

In case of exception in a listener, the transaction is rolled back for that listener but processing continues for the other listeners.

In case of timeout, an error is logged but processing continues for the other listeners (the thread is left running separately from the main thread that initiated post-commit processing).

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
EventBundleRunner(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 Detail

listeners

protected final List<EventListenerDescriptor> listeners

bundle

protected final EventBundle bundle

traceContext

protected final byte[] traceContext

callerThread

protected String callerThread

Constructor Detail

EventBundleRunner

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

Method Detail

call

public Boolean call()

Specified by:

call in interface Callable<Boolean>

getTracingSpan

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