| Package | Description |
|---|---|
| org.d_haven.event | |
| org.d_haven.event.impl |
| Modifier and Type | Method and Description |
|---|---|
PreparedEnqueue |
Sink.prepareEnqueue(java.lang.Object[] elements)
Support for transactional enqueue.
|
| Modifier and Type | Class and Description |
|---|---|
private static class |
DefaultPipe.DefaultPreparedEnqueue |
private static class |
MultiCastSink.MultiCastPreparedEnqueue
A prepared enqueue object that holds other prepared enqueue
objects and allows to perform a commit / abort on all of these
objects.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract PreparedEnqueue |
AbstractPipe.doPrepareEnqueue(java.lang.Object[] elements)
Abstract method provided to allow the child classes to focus only
on the portion of code needed to do a prepared enqueue for the
supplied events.
|
protected PreparedEnqueue |
DefaultPipe.doPrepareEnqueue(java.lang.Object[] elements) |
PreparedEnqueue |
MultiCastSink.prepareEnqueue(java.lang.Object[] elements) |
PreparedEnqueue |
AbstractPipe.prepareEnqueue(java.lang.Object[] elements)
Support for transactional enqueue.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MultiCastSink.MultiCastPreparedEnqueue.addPreparedEnqueue(PreparedEnqueue preparedEnqueue)
Adds a prepared enqueue object to the list of prepared
enqueues.
|