Uses of Interface
org.d_haven.event.EnqueuePredicate

Packages that use EnqueuePredicate

Package	Description
org.d_haven.event
org.d_haven.event.command
org.d_haven.event.impl

Uses of EnqueuePredicate in org.d_haven.event

Methods in org.d_haven.event that return EnqueuePredicate

Modifier and Type	Method and Description
EnqueuePredicate	Pipe.getEnqueuePredicate() Return the enqueue predicate for this sink.

Methods in org.d_haven.event with parameters of type EnqueuePredicate

Modifier and Type	Method and Description
void	Pipe.setEnqueuePredicate(EnqueuePredicate enqueuePredicate) Set the enqueue predicate for this sink.

Uses of EnqueuePredicate in org.d_haven.event.command

Classes in org.d_haven.event.command that implement EnqueuePredicate

Modifier and Type	Class and Description
class	SwitchedEnqueuePredicate The SwitchedEnqueuePredicate provides a mechanism where we can explicitly tell the queue whether we are accepting new events or not.

Constructors in org.d_haven.event.command with parameters of type EnqueuePredicate

Constructor and Description
CommandEventPipeline(EnqueuePredicate predicate, EventHandler handler) The CommandEventPipeline is used to manage the incomming queue of commands, the queue of commands to run later, and the event handler to pass the commands to.

Uses of EnqueuePredicate in org.d_haven.event.impl

Classes in org.d_haven.event.impl that implement EnqueuePredicate

Modifier and Type	Class and Description
class	NullEnqueuePredicate The NullEnqueuePredicate does nothing to limit a Pipe's ability to enqueue.
class	RateLimitingPredicate This enqueue predicate implements input rate policing.
class	ThresholdEnqueuePredicate The ThresholdEnqueuePredicate limits the elements that can be enqueued based on the size of the Pipe.

Fields in org.d_haven.event.impl declared as EnqueuePredicate

Modifier and Type	Field and Description
protected EnqueuePredicate	AbstractPipe.m_predicate The EnqueuePredicate used.

Methods in org.d_haven.event.impl that return EnqueuePredicate

Modifier and Type	Method and Description
EnqueuePredicate	AbstractPipe.getEnqueuePredicate() Return the EnqueuePredicate that is already set for this Pipe.

Methods in org.d_haven.event.impl with parameters of type EnqueuePredicate

Modifier and Type	Method and Description
void	AbstractPipe.setEnqueuePredicate(EnqueuePredicate predicate) Set the EnqueuePredicate to limit entries into this Pipe.

Constructors in org.d_haven.event.impl with parameters of type EnqueuePredicate

Constructor and Description
DefaultPipe(EnqueuePredicate predicate) Construct a new DefaultPipe with the supplied EnqueuePredicate.