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.

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
static String	TIMEOUT_MS_PROP

Constructor Summary

Constructors

Constructor and Description
PostCommitEventExecutor()

Method Summary

Methods

Modifier and Type	Method and Description
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

equals, 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

Constructor Detail

PostCommitEventExecutor

public PostCommitEventExecutor()

Method Detail

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)