Package org.d_haven.event.impl

Class Summary
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.