Uses of Interface
org.d_haven.event.EnqueuePredicate

Packages that use EnqueuePredicate
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
 EnqueuePredicate Pipe.getEnqueuePredicate()
          Return the enqueue predicate for this sink.
 

Methods in org.d_haven.event with parameters of type EnqueuePredicate
 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
 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
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
 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
protected  EnqueuePredicate AbstractPipe.m_predicate
          The EnqueuePredicate used.
 

Methods in org.d_haven.event.impl that return EnqueuePredicate
 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
 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
DefaultPipe(EnqueuePredicate predicate)
          Construct a new DefaultPipe with the supplied EnqueuePredicate.