Class Summary |
AbstractEventHandler |
Created by IntelliJ IDEA. |
AbstractPipe |
Provides the base functionality for the other Pipe
types.
|
AbstractThreadPolicy |
The AbstractThreadPolicy keeps track of wether the management thread
is running or not, and stores the ThreadManager for future use. |
Command |
A Command is a specific type of event that denotes an asynchronous
execution unit that must be performed by the DefaultCommandManager.
|
CommandEventHandler |
The CommandEventHandler is used by the DefaultCommandManager to
actually process the events. |
CommandEventPipeline |
Created by IntelliJ IDEA. |
CommandFailureHandler |
CommandFailureHandler is used by the DefaultCommandManager to handle
any exceptions that might be thrown by a Command. |
CommandManager |
Created by IntelliJ IDEA. |
DefaultCommandFailureHandler |
DefaultCommandFailureHandler is used to do nothing if a command
fails.
|
DefaultCommandManager |
The DefaultCommandManager handles asynchronous commands from the rest
of the system. |
DefaultCommandManager.DelayedCommandInfo |
This class encapsulates the information needed to keep track of
our progress executing delayed and repeated commands. |
DefaultPipe |
The default queue implementation is a variable size queue. |
DefaultPipe.DefaultPreparedEnqueue | |
DefaultThreadManager |
The DefaultThreadManager is a very flexible implementation that
should be able to solve just about any need. |
DelayedCommand |
A DelayedCommand is a specific type of Command that denotes a an
execution unit that will be delayed at least X number of
milliseconds. |
DequeueInterceptor |
The dequeue executable interface describes operations that are
executed before and after elements are pulled from a queue.
|
EnqueuePredicate |
Enqueue predicates allow users to specify a method that will 'screen'
elements being enqueued onto a sink, either accepting or rejecting
them. |
EnqueuePredicateFailedException |
If the EnqueuePredicate returns false, denying an event to the Sink,
the Sink will throw this exception.
|
EventHandler |
An EventHandler takes care of processing specific events
in an event-based architecture.
|
EventPipeline |
An EventPipeline is used by the ThreadManager to manage the event
Pipe and EventHandler relationship. |
EventPipelineRunner |
Created by IntelliJ IDEA. |
GroupedThreadFactory |
The GroupedThreadFactory is a convenience implementation for the
concurrent utilitie's ThreadFactory. |
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.
|
NullCommandFailureHandler |
DefaultCommandFailureHandler is used to do nothing if a command
fails.
|
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. |
OneThreadPolicy |
Created by IntelliJ IDEA. |
Pipe |
A Source implements the side of an event queue where QueueElements
are dequeued operations only.
|
PreparedEnqueue |
A PreparedEnqueue is an object returned from a
prepareEnqueue method that allows you to either commit
or abort the enqueue operation.
|
ProcessorBoundThreadPolicy |
The ProcessorBoundThreadPolicy is a ThreadPolicy designed to process
pipelines in a number of threads that is a multiple of the number of
threads in the system. |
RateLimitingPredicate |
This enqueue predicate implements input rate policing.
|
RepeatedCommand |
The RepeatedCommand is used to represent a command that operates at a
specified interval over time. |
Sink |
A Sink implements the end of a finite-length event queue where
elements are enqueued. |
SinkClosedException |
A SinkClosedException is thrown when an enqueue operation occurs on a
queue that is already closed.
|
SinkException |
A SourceException is thrown when an enqueue operation fails.
|
SinkFullException |
A SinkException is thrown when an enqueue operation occurs on a queue
that is already full.
|
Source |
A Source implements the side of an event queue where QueueElements
are dequeued operations only.
|
SwitchedEnqueuePredicate |
The SwitchedEnqueuePredicate provides a mechanism where we can
explicitly tell the queue whether we are accepting new events or not.
|
ThreadManager |
A ThreadManager handles the thread policies for EventPipelines. |
ThreadPolicy |
The ThreadPolicy is used to control how the EventPipelineRunner is
set up, and how new threads are created and destroyed over the life
of the system. |
ThresholdEnqueuePredicate |
The ThresholdEnqueuePredicate limits the elements that can be
enqueued based on the size of the Pipe. |