- abort() - Method in class org.d_haven.event.impl.DefaultPipe.DefaultPreparedEnqueue
-
- abort() - Method in class org.d_haven.event.impl.MultiCastSink.MultiCastPreparedEnqueue
-
- abort() - Method in interface org.d_haven.event.PreparedEnqueue
-
Abort a previously prepared provisional enqueue operation (from
the prepareEnqueue method).
- AbstractEventHandler - Class in org.d_haven.event.impl
-
Created by IntelliJ IDEA.
- AbstractEventHandler() - Constructor for class org.d_haven.event.impl.AbstractEventHandler
-
- AbstractPipe - Class in org.d_haven.event.impl
-
Provides the base functionality for the other Pipe
types.
- AbstractPipe() - Constructor for class org.d_haven.event.impl.AbstractPipe
-
- AbstractThreadPolicy - Class in org.d_haven.event.command
-
The AbstractThreadPolicy keeps track of wether the management thread
is running or not, and stores the ThreadManager for future use.
- AbstractThreadPolicy() - Constructor for class org.d_haven.event.command.AbstractThreadPolicy
-
- accept(Object, Sink) - Method in class org.d_haven.event.command.SwitchedEnqueuePredicate
-
Tests the given element for acceptance onto the m_sink.
- accept(Object[], Sink) - Method in class org.d_haven.event.command.SwitchedEnqueuePredicate
-
Tests the given element for acceptance onto the m_sink.
- accept() - Method in class org.d_haven.event.command.SwitchedEnqueuePredicate
-
Tell this EnqueuePredicate to start allowing new events to be
enqueued.
- accept(Object, Sink) - Method in interface org.d_haven.event.EnqueuePredicate
-
Tests the given element for acceptance onto the m_sink.
- accept(Object[], Sink) - Method in interface org.d_haven.event.EnqueuePredicate
-
Tests the given element for acceptance onto the m_sink.
- accept(Object, Sink) - Method in class org.d_haven.event.impl.NullEnqueuePredicate
-
- accept(Object[], Sink) - Method in class org.d_haven.event.impl.NullEnqueuePredicate
-
- accept(Object, Sink) - Method in class org.d_haven.event.impl.RateLimitingPredicate
-
- accept(Object[], Sink) - Method in class org.d_haven.event.impl.RateLimitingPredicate
-
- accept(Object, Sink) - Method in class org.d_haven.event.impl.ThresholdEnqueuePredicate
-
Returns true if the Sink size + 1 (the element) is less than the
threshold.
- accept(Object[], Sink) - Method in class org.d_haven.event.impl.ThresholdEnqueuePredicate
-
Returns true if the Sink size + the number of elements is less
than the threshold.
- addPreparedEnqueue(PreparedEnqueue) - Method in class org.d_haven.event.impl.MultiCastSink.MultiCastPreparedEnqueue
-
Adds a prepared enqueue object to the list of prepared
enqueues.
- after(Source) - Method in interface org.d_haven.event.DequeueInterceptor
-
An operation executed after dequeing events from the queue.
- after(Source) - Method in class org.d_haven.event.impl.NullDequeueInterceptor
-
An operation executed after dequeing events from the queue.
- DEFAULT_WAIT_TIME - Static variable in class org.d_haven.event.command.ProcessorBoundThreadPolicy
-
- DefaultCommandFailureHandler - Class in org.d_haven.event.command
-
DefaultCommandFailureHandler is used to do nothing if a command
fails.
- DefaultCommandFailureHandler() - Constructor for class org.d_haven.event.command.DefaultCommandFailureHandler
-
- DefaultCommandManager - Class in org.d_haven.event.command
-
The DefaultCommandManager handles asynchronous commands from the rest
of the system.
- DefaultCommandManager(ThreadManager) - Constructor for class org.d_haven.event.command.DefaultCommandManager
-
Create the DefaultCommandManager using the supplied
ThreadManager.
- DefaultCommandManager.DelayedCommandInfo - Class in org.d_haven.event.command
-
This class encapsulates the information needed to keep track of
our progress executing delayed and repeated commands.
- DefaultCommandManager.DelayedCommandInfo() - Constructor for class org.d_haven.event.command.DefaultCommandManager.DelayedCommandInfo
-
- DefaultPipe - Class in org.d_haven.event.impl
-
The default queue implementation is a variable size queue.
- DefaultPipe() - Constructor for class org.d_haven.event.impl.DefaultPipe
-
Create an unbounded DefaultPipe.
- DefaultPipe(int) - Constructor for class org.d_haven.event.impl.DefaultPipe
-
Construct a new DefaultPipe with the specified number of
elements.
- DefaultPipe(EnqueuePredicate) - Constructor for class org.d_haven.event.impl.DefaultPipe
-
Construct a new DefaultPipe with the supplied EnqueuePredicate.
- DefaultPipe.DefaultPreparedEnqueue - Class in org.d_haven.event.impl
-
- DefaultPipe.DefaultPreparedEnqueue(DefaultPipe, Object[]) - Constructor for class org.d_haven.event.impl.DefaultPipe.DefaultPreparedEnqueue
-
- DefaultThreadManager - Class in org.d_haven.event.command
-
The DefaultThreadManager is a very flexible implementation that
should be able to solve just about any need.
- DefaultThreadManager() - Constructor for class org.d_haven.event.command.DefaultThreadManager
-
Create the DefaultThreadManager using the OneThreadPolicy as the
way to run events through the pipelines.
- DefaultThreadManager(ThreadPolicy) - Constructor for class org.d_haven.event.command.DefaultThreadManager
-
Create the DefaultThreadManager using the ThreadPolicy of your
choice.
- DelayedCommand - Interface in org.d_haven.event.command
-
A DelayedCommand is a specific type of Command that denotes a an
execution unit that will be delayed at least X number of
milliseconds.
- dequeue() - Method in class org.d_haven.event.impl.AbstractPipe
-
Dequeues the next element, or null if there is
nothing left on the queue or in case of a timeout while
attempting to obtain the mutex.
- dequeue(int) - Method in class org.d_haven.event.impl.AbstractPipe
-
Dequeues at most num available elements.
- dequeue() - Method in interface org.d_haven.event.Source
-
Dequeues the next element, or null if there is
nothing left on the queue or in case of a timeout while
attempting to obtain the mutex.
- dequeue(int) - Method in interface org.d_haven.event.Source
-
Dequeues at most num available elements.
- dequeueAll() - Method in class org.d_haven.event.impl.AbstractPipe
-
Dequeues all available elements.
- dequeueAll() - Method in interface org.d_haven.event.Source
-
Dequeues all available elements.
- DequeueInterceptor - Interface in org.d_haven.event
-
The dequeue executable interface describes operations that are
executed before and after elements are pulled from a queue.
- doDequeue() - Method in class org.d_haven.event.impl.AbstractPipe
-
Abstract method to allow child classes to only focus on the part
necessary to dequeue one event.
- doDequeue(int) - Method in class org.d_haven.event.impl.AbstractPipe
-
Abstract method to allow child classes to only focus on the part
necessary to dequeue the supplied number of events.
- doDequeue(int) - Method in class org.d_haven.event.impl.DefaultPipe
-
- doDequeue() - Method in class org.d_haven.event.impl.DefaultPipe
-
- doDequeueAll() - Method in class org.d_haven.event.impl.AbstractPipe
-
Abstract method to allow child classes to only focus on the part
necessary to dequeue the remaining events.
- doDequeueAll() - Method in class org.d_haven.event.impl.DefaultPipe
-
- doEnqueue(Object) - Method in class org.d_haven.event.impl.AbstractPipe
-
Abstract method provided to allow the child classes to focus only
on the portion of code needed to enqueue one event.
- doEnqueue(Object[]) - Method in class org.d_haven.event.impl.AbstractPipe
-
Abstract method provided to allow the child classes to focus only
on the portion of code needed to enqueue the supplied events.
- doEnqueue(Object[]) - Method in class org.d_haven.event.impl.DefaultPipe
-
- doEnqueue(Object) - Method in class org.d_haven.event.impl.DefaultPipe
-
- doPrepareEnqueue(Object[]) - Method in class org.d_haven.event.impl.AbstractPipe
-
Abstract method provided to allow the child classes to focus only
on the portion of code needed to do a prepared enqueue for the
supplied events.
- doPrepareEnqueue(Object[]) - Method in class org.d_haven.event.impl.DefaultPipe
-
- endLoop() - Method in class org.d_haven.event.command.AbstractThreadPolicy
-
Provide a hook to do further cleanup when we end the management
loop.
- endLoop() - Method in class org.d_haven.event.command.ProcessorBoundThreadPolicy
-
- enqueue(Object) - Method in class org.d_haven.event.impl.AbstractPipe
-
Enqueues the given element onto the Sink.
- enqueue(Object[]) - Method in class org.d_haven.event.impl.AbstractPipe
-
Given an array of elements, atomically enqueues all of the
elements in the array.
- enqueue(Object) - Method in class org.d_haven.event.impl.MultiCastSink
-
- enqueue(Object[]) - Method in class org.d_haven.event.impl.MultiCastSink
-
- enqueue(Object) - Method in interface org.d_haven.event.Sink
-
Enqueues the given element onto the Sink.
- enqueue(Object[]) - Method in interface org.d_haven.event.Sink
-
Given an array of elements, atomically enqueues all of the
elements in the array.
- enqueueCommand(Command) - Method in interface org.d_haven.event.command.CommandManager
-
Add a command to the manager for it to execute.
- enqueueCommand(Command) - Method in class org.d_haven.event.command.DefaultCommandManager
-
Get the Command Sink so that you can enqueue new commands.
- EnqueuePredicate - Interface in org.d_haven.event
-
Enqueue predicates allow users to specify a method that will 'screen'
elements being enqueued onto a sink, either accepting or rejecting
them.
- EnqueuePredicateFailedException - Exception in org.d_haven.event
-
If the EnqueuePredicate returns false, denying an event to the Sink,
the Sink will throw this exception.
- EnqueuePredicateFailedException(String) - Constructor for exception org.d_haven.event.EnqueuePredicateFailedException
-
Construct a new SinkException instance.
- EnqueuePredicateFailedException(String, Exception) - Constructor for exception org.d_haven.event.EnqueuePredicateFailedException
-
Construct a new SinkException instance.
- EventHandler - Interface in org.d_haven.event
-
An EventHandler takes care of processing specific events
in an event-based architecture.
- EventPipeline - Interface in org.d_haven.event.command
-
An EventPipeline is used by the ThreadManager to manage the event
Pipe and EventHandler relationship.
- EventPipelineRunner - Class in org.d_haven.event.command
-
Created by IntelliJ IDEA.
- EventPipelineRunner(EventPipeline) - Constructor for class org.d_haven.event.command.EventPipelineRunner
-
Create an EventPipelineRunner with the supplied pipeline and a
policy of dequeueing one entry at a time.
- EventPipelineRunner(EventPipeline, int) - Constructor for class org.d_haven.event.command.EventPipelineRunner
-
Create an EventPipelineRunner with the supplied pipeline and
number of events to dequeue at a time.
- execute() - Method in interface org.d_haven.event.command.Command
-
The code to execute when the CommandManager acts on it.
- executeLoop(ThreadManager) - Method in class org.d_haven.event.command.AbstractThreadPolicy
-
- executeLoop(ThreadManager) - Method in interface org.d_haven.event.command.ThreadPolicy
-
Execute the management loop.
- getBucketSize() - Method in class org.d_haven.event.impl.RateLimitingPredicate
-
Returns the number of tokens currently in the bucket.
- getCommandFailureHandler() - Method in class org.d_haven.event.command.CommandEventHandler
-
Get the CommandFailureHandler in use for this event handler.
- getCommandFailureHandler() - Method in class org.d_haven.event.command.DefaultCommandManager
-
Get the failure handler so that DefaultCommandManager can use it
when a problem happens.
- getDelayInterval() - Method in interface org.d_haven.event.command.DelayedCommand
-
Sets the initial delay for the Command.
- getDepth() - Method in class org.d_haven.event.impl.RateLimitingPredicate
-
Returns the current depth.
- getDequeueInterceptor() - Method in class org.d_haven.event.impl.AbstractPipe
-
Return the dequeue executable for this sink.
- getDequeueInterceptor() - Method in interface org.d_haven.event.Pipe
-
Return the dequeue executable for this sink.
- getEnqueuedCommandSize() - Method in class org.d_haven.event.command.DefaultCommandManager
-
Get the number of currently enqueued commands.
- getEnqueuePredicate() - Method in class org.d_haven.event.impl.AbstractPipe
-
Return the EnqueuePredicate that is already set for this Pipe.
- getEnqueuePredicate() - Method in interface org.d_haven.event.Pipe
-
Return the enqueue predicate for this sink.
- getEventHandler() - Method in class org.d_haven.event.command.CommandEventPipeline
-
Used by the ThreadManager to get the EventHandler for the
DefaultCommandManager.
- getEventHandler() - Method in interface org.d_haven.event.command.EventPipeline
-
Returns the reference to the EventHandler that the events from
all the Sinks get merged into.
- getIncomingSink() - Method in class org.d_haven.event.command.CommandEventPipeline
-
Provide a way to get the Sink to send new Commands to.
- getNumberOfRepeats() - Method in interface org.d_haven.event.command.RepeatedCommand
-
If the value is less than 1 (0 or negative), the command repeats
for as long as the DefaultCommandManager is running.
- getNumEntries() - Method in class org.d_haven.event.command.EventPipelineRunner
-
Return the number of entries to process at one time.
- getNumThreads() - Method in class org.d_haven.event.command.ProcessorBoundThreadPolicy
-
Get the number of threads to use for running the pipelines.
- getPipeline() - Method in class org.d_haven.event.command.EventPipelineRunner
-
Get the pipeline we are processing at this time.
- getRecurringSink() - Method in class org.d_haven.event.command.CommandEventPipeline
-
Provide a way to get the Sink to requeue delayed Commands to.
- getRegisteredPipelines() - Method in class org.d_haven.event.command.DefaultThreadManager
-
Return a copy of all the pipelines registered at this point.
- getRegisteredPipelines() - Method in interface org.d_haven.event.command.ThreadManager
-
Get the collection of registered pipelines.
- getRepeatInterval() - Method in interface org.d_haven.event.command.RepeatedCommand
-
Gets the repeat interval so that the CommandQueue keeps it for
the specified amount of time before enqueuing it again.
- getSources() - Method in class org.d_haven.event.command.CommandEventPipeline
-
Used by the Threadmanager to get the sources that are feeding the
DefaultCommandManager.
- getSources() - Method in interface org.d_haven.event.command.EventPipeline
-
There can be many different sources to merge into a pipeline.
- getTargetRate() - Method in class org.d_haven.event.impl.RateLimitingPredicate
-
Returns the current rate limit.
- getThreadFactory() - Method in class org.d_haven.event.command.ProcessorBoundThreadPolicy
-
Get the ThreadFactory used to create new threads.
- getThreadManager() - Method in class org.d_haven.event.command.DefaultCommandManager
-
Get the ThreadManager we are using for this CommandManager.
- getThreshold() - Method in class org.d_haven.event.impl.ThresholdEnqueuePredicate
-
Get the threshold size.
- getWaitTime() - Method in class org.d_haven.event.command.ProcessorBoundThreadPolicy
-
Get the time we wait between runs of the pipeline.
- GroupedThreadFactory - Class in org.d_haven.event.command
-
The GroupedThreadFactory is a convenience implementation for the
concurrent utilitie's ThreadFactory.
- GroupedThreadFactory() - Constructor for class org.d_haven.event.command.GroupedThreadFactory
-
Create a GroupedThreadFactory with the current thread's
ThreadGroup.
- GroupedThreadFactory(ThreadGroup) - Constructor for class org.d_haven.event.command.GroupedThreadFactory
-
Create a GroupedThreadFactory with the ThreadGroup supplied.
- SECOND - Static variable in class org.d_haven.event.impl.RateLimitingPredicate
-
- setCommandEventPipeline(CommandEventPipeline) - Method in class org.d_haven.event.command.CommandEventHandler
-
Provide the CommandEventPipeline to use for requeueing delayed
and repeating commands.
- setCommandFailureHandler(CommandFailureHandler) - Method in class org.d_haven.event.command.CommandEventHandler
-
Set the CommandFailureHandler to use with this event handler.
- setCommandFailureHandler(CommandFailureHandler) - Method in interface org.d_haven.event.command.CommandManager
-
Set the failure handler that the application can use to override
what happens when a command failure happens.
- setCommandFailureHandler(CommandFailureHandler) - Method in class org.d_haven.event.command.DefaultCommandManager
-
Set the failure handler that the application can use to override
what happens when a command failure happens.
- setDepth(int) - Method in class org.d_haven.event.impl.RateLimitingPredicate
-
Allows to set the bucket depth.
- setDequeueInterceptor(DequeueInterceptor) - Method in class org.d_haven.event.impl.AbstractPipe
-
Set the dequeue executable for this sink.
- setDequeueInterceptor(DequeueInterceptor) - Method in interface org.d_haven.event.Pipe
-
Set the dequeue executable for this sink.
- setEnqueuePredicate(EnqueuePredicate) - Method in class org.d_haven.event.impl.AbstractPipe
-
Set the EnqueuePredicate to limit entries into this Pipe.
- setEnqueuePredicate(EnqueuePredicate) - Method in interface org.d_haven.event.Pipe
-
Set the enqueue predicate for this sink.
- setTargetRate(double) - Method in class org.d_haven.event.impl.RateLimitingPredicate
-
Allows to set the rate limit.
- setThreadFactory(ThreadFactory) - Method in class org.d_haven.event.command.OneThreadPolicy
-
- setThreadFactory(ThreadFactory) - Method in class org.d_haven.event.command.ProcessorBoundThreadPolicy
-
- setThreadFactory(ThreadFactory) - Method in interface org.d_haven.event.command.ThreadPolicy
-
Set the ThreadFactory for the policy to use.
- setTimeout(long) - Method in class org.d_haven.event.impl.AbstractPipe
-
Set the timeout for the Pipe in milliseconds.
- setTimeout(long) - Method in interface org.d_haven.event.Source
-
Sets the timeout on a blocking Source.
- Sink - Interface in org.d_haven.event
-
A Sink implements the end of a finite-length event queue where
elements are enqueued.
- SinkClosedException - Exception in org.d_haven.event
-
A SinkClosedException is thrown when an enqueue operation occurs on a
queue that is already closed.
- SinkClosedException(String) - Constructor for exception org.d_haven.event.SinkClosedException
-
Create a SinkClosedException with an associated
message.
- SinkClosedException(String, Exception) - Constructor for exception org.d_haven.event.SinkClosedException
-
Create a SinkClosedException with an associated
message and the original exception that caused the problem.
- SinkException - Exception in org.d_haven.event
-
A SourceException is thrown when an enqueue operation fails.
- SinkException(String) - Constructor for exception org.d_haven.event.SinkException
-
Construct a new SinkException instance.
- SinkException(String, Exception) - Constructor for exception org.d_haven.event.SinkException
-
Construct a new SinkException instance.
- SinkFullException - Exception in org.d_haven.event
-
A SinkException is thrown when an enqueue operation occurs on a queue
that is already full.
- SinkFullException(String) - Constructor for exception org.d_haven.event.SinkFullException
-
Create a SinkFullException with an associated
message.
- SinkFullException(String, Exception) - Constructor for exception org.d_haven.event.SinkFullException
-
Create a SinkClosedException with an associated
message and the original exception that caused the problem.
- size() - Method in class org.d_haven.event.impl.DefaultPipe
-
Return the number of elements currently in the
Pipe.
- size() - Method in class org.d_haven.event.impl.MultiCastSink
-
- size() - Method in interface org.d_haven.event.Sink
-
Returns the number of elements waiting in this Sink.
- size() - Method in interface org.d_haven.event.Source
-
Returns the number of elements waiting in this Source.
- Source - Interface in org.d_haven.event
-
A Source implements the side of an event queue where QueueElements
are dequeued operations only.
- start() - Method in interface org.d_haven.event.command.CommandManager
-
Start or restart the CommandManager so that it can accept more
commands.
- start() - Method in class org.d_haven.event.command.DefaultCommandManager
-
- startLoop() - Method in class org.d_haven.event.command.AbstractThreadPolicy
-
Provide a hook to do further initialization when we start the
management loop.
- startLoop() - Method in class org.d_haven.event.command.OneThreadPolicy
-
- startLoop() - Method in class org.d_haven.event.command.ProcessorBoundThreadPolicy
-
- stop(boolean) - Method in interface org.d_haven.event.command.CommandManager
-
Stop the CommandManager so that it can stop accepting commands.
- stop(boolean) - Method in class org.d_haven.event.command.DefaultCommandManager
-
- stop() - Method in class org.d_haven.event.command.DefaultThreadManager
-
Stop the ThreadManager from running the pipelines.
- stop() - Method in interface org.d_haven.event.command.ThreadManager
-
Stop managing the pipelines, and shut down all threads in use.
- SwitchedEnqueuePredicate - Class in org.d_haven.event.command
-
The SwitchedEnqueuePredicate provides a mechanism where we can
explicitly tell the queue whether we are accepting new events or not.
- SwitchedEnqueuePredicate() - Constructor for class org.d_haven.event.command.SwitchedEnqueuePredicate
-
Create a SwitchedEnqueuePredicate.