| Package | Description |
|---|---|
| org.d_haven.event | |
| org.d_haven.event.command | |
| org.d_haven.event.impl |
| Modifier and Type | Class and Description |
|---|---|
class |
EnqueuePredicateFailedException
If the EnqueuePredicate returns false, denying an event to the Sink,
the Sink will throw this exception.
|
class |
SinkClosedException
A SinkClosedException is thrown when an enqueue operation occurs on a
queue that is already closed.
|
class |
SinkFullException
A SinkException is thrown when an enqueue operation occurs on a queue
that is already full.
|
| Modifier and Type | Method and Description |
|---|---|
void |
Sink.enqueue(java.lang.Object element)
Enqueues the given element onto the Sink.
|
void |
Sink.enqueue(java.lang.Object[] elements)
Given an array of elements, atomically enqueues all of the
elements in the array.
|
PreparedEnqueue |
Sink.prepareEnqueue(java.lang.Object[] elements)
Support for transactional enqueue.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CommandManager.enqueueCommand(Command command)
Add a command to the manager for it to execute.
|
void |
DefaultCommandManager.enqueueCommand(Command command)
Get the Command Sink so that you can enqueue new commands.
|
private boolean |
CommandEventHandler.timeToRequeue(DefaultCommandManager.DelayedCommandInfo info) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
AbstractPipe.doEnqueue(java.lang.Object element)
Abstract method provided to allow the child classes to focus only
on the portion of code needed to enqueue one event.
|
protected abstract void |
AbstractPipe.doEnqueue(java.lang.Object[] elements)
Abstract method provided to allow the child classes to focus only
on the portion of code needed to enqueue the supplied events.
|
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.
|
void |
MultiCastSink.enqueue(java.lang.Object element) |
void |
AbstractPipe.enqueue(java.lang.Object element)
Enqueues the given element onto the Sink.
|
void |
MultiCastSink.enqueue(java.lang.Object[] elements) |
void |
AbstractPipe.enqueue(java.lang.Object[] elements)
Given an array of elements, atomically enqueues all of the
elements in the array.
|
PreparedEnqueue |
MultiCastSink.prepareEnqueue(java.lang.Object[] elements) |
PreparedEnqueue |
AbstractPipe.prepareEnqueue(java.lang.Object[] elements)
Support for transactional enqueue.
|