| Package | Description |
|---|---|
| org.apache.excalibur.event |
| Modifier and Type | Class and Description |
|---|---|
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.
|