public class PostCommitEventExecutor extends Object
Allows a bulk mode where transaction management is not per-listener done once for the whole set of listeners.
Modifier and Type | Class and Description |
---|---|
protected static class |
PostCommitEventExecutor.EventBundleBulkRunner
Lets the listeners process the event bundle in bulk mode.
|
protected static class |
PostCommitEventExecutor.EventBundleRunner
Lets the listeners process the event bundle.
|
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 |
protected ExecutorService |
executor |
static String |
TIMEOUT_MS_PROP |
Constructor and Description |
---|
PostCommitEventExecutor() |
Modifier and Type | Method and Description |
---|---|
protected int |
getDefaultTimeoutMs() |
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) |
public static final String TIMEOUT_MS_PROP
public static final int DEFAULT_TIMEOUT_MS
public static final int DEFAULT_TIMEOUT_TEST_MS
public static final String DEFAULT_BULK_TIMEOUT_S
public static final String BULK_TIMEOUT_PROP
protected final ExecutorService executor
public PostCommitEventExecutor()
protected int getDefaultTimeoutMs()
public void shutdown(long timeoutMillis) throws InterruptedException
InterruptedException
public void run(List<EventListenerDescriptor> listeners, EventBundle event)
public void runBulk(List<EventListenerDescriptor> listeners, EventBundle event)
public void run(List<EventListenerDescriptor> listeners, EventBundle bundle, long timeoutMillis, boolean bulk)
Copyright © 2018 Nuxeo. All rights reserved.