|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use PreparedEnqueue | |
|---|---|
| org.d_haven.event | |
| org.d_haven.event.impl | |
| Uses of PreparedEnqueue in org.d_haven.event |
|---|
| Methods in org.d_haven.event that return PreparedEnqueue | |
|---|---|
PreparedEnqueue |
Sink.prepareEnqueue(java.lang.Object[] elements)
Support for transactional enqueue. |
| Uses of PreparedEnqueue in org.d_haven.event.impl |
|---|
| Classes in org.d_haven.event.impl that implement PreparedEnqueue | |
|---|---|
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. |
| Methods in org.d_haven.event.impl that return PreparedEnqueue | |
|---|---|
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 |
AbstractPipe.prepareEnqueue(java.lang.Object[] elements)
Support for transactional enqueue. |
PreparedEnqueue |
MultiCastSink.prepareEnqueue(java.lang.Object[] elements)
|
| Methods in org.d_haven.event.impl with parameters of type PreparedEnqueue | |
|---|---|
void |
MultiCastSink.MultiCastPreparedEnqueue.addPreparedEnqueue(PreparedEnqueue preparedEnqueue)
Adds a prepared enqueue object to the list of prepared enqueues. |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||