| Class | Description |
|---|---|
| AbstractEventHandler |
Created by IntelliJ IDEA.
|
| AbstractPipe |
Provides the base functionality for the other
Pipe
types. |
| DefaultPipe |
The default queue implementation is a variable size queue.
|
| DefaultPipe.DefaultPreparedEnqueue | |
| MultiCastSink |
This is a
Sink implementation that
multicasts enqueue operations to the contained and concrete sink
objects. |
| MultiCastSink.MultiCastPreparedEnqueue |
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 Pipe'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 Pipe.
|