|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |