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 | 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 and Description |
---|
PostCommitEventExecutor() |
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) |
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
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 © 2015 Nuxeo SA. All rights reserved.