| Class | Description |
|---|---|
| AbstractQueue |
Provides the base functionality for the other
Queue types. |
| DefaultQueue |
The default queue implementation is a variable size queue.
|
| DefaultQueue.DefaultPreparedEnqueue | |
| FixedSizeQueue | Deprecated
Use the DefaultQueue as it properly supports the EnqueuePredicates
|
| FixedSizeQueue.FixedSizePreparedEnqueue | |
| LossyMultiCastSink |
This is a
org.apache.excalibur.event.seda.event.Sink
implementation that multicasts enqueue operations to the
contained and concrete sink objects. |
| LossyMultiCastSink.DefaultPreparedEnqueue |
A prepared enqueue object that holds other prepared
enqueue objects and allows to perform a commit / abort
on all of these objects.
|
| MultiCastSink |
This is a
org.apache.excalibur.event.seda.event.Sink
implementation that multicasts enqueue operations to the
contained and concrete sink objects. |
| MultiCastSink.DefaultPreparedEnqueue |
A prepared enqueue object that holds other prepared
enqueue objects and allows to perform a commit / abort
on all of these objects.
|
| NullDequeueInterceptor |
The dequeue executable interface describes operations that
are executed before and after elements are pulled from a
queue.
|
| NullEnqueuePredicate |
The NullEnqueuePredicate does nothing to limit a Queue's ability to enqueue.
|
| RateLimitingPredicate |
This enqueue predicate implements input rate policing.
|
| ThresholdEnqueuePredicate |
The ThresholdEnqueuePredicate limits the elements that can be enqueued
based on the size of the Queue.
|