Index

A B C D E F G H I L M N O P R S T V W Y

A

abort() - Method in class org.apache.excalibur.event.impl.DefaultQueue.DefaultPreparedEnqueue
abort() - Method in class org.apache.excalibur.event.impl.FixedSizeQueue.FixedSizePreparedEnqueue: Deprecated.
abort() - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink.DefaultPreparedEnqueue
abort() - Method in class org.apache.excalibur.event.impl.MultiCastSink.DefaultPreparedEnqueue
AbstractQueue - Class in org.apache.excalibur.event.impl: Provides the base functionality for the other Queue types.
AbstractQueue() - Constructor for class org.apache.excalibur.event.impl.AbstractQueue
AbstractThreadManager - Class in org.apache.excalibur.event.command: Abstract base class for a ThreadManager that has a single ThreadPool for all pipelines
AbstractThreadManager() - Constructor for class org.apache.excalibur.event.command.AbstractThreadManager
AbstractThreadManager.PipelineRunner - Class in org.apache.excalibur.event.command: The PipelineRunner class pulls all the events from the Source, and puts them in the EventHandler.
AbstractThreadManager.PipelineRunner(EventPipeline) - Constructor for class org.apache.excalibur.event.command.AbstractThreadManager.PipelineRunner: Create a PipelineRunner.
accept(Object, Sink) - Method in class org.apache.excalibur.event.command.CommandManager: Tests the given element for acceptance onto the m_sink.
accept(Object[], Sink) - Method in class org.apache.excalibur.event.command.CommandManager: Tests the given element for acceptance onto the m_sink.
accept(Object, Sink) - Method in class org.apache.excalibur.event.impl.NullEnqueuePredicate
accept(Object[], Sink) - Method in class org.apache.excalibur.event.impl.NullEnqueuePredicate
accept(Object, Sink) - Method in class org.apache.excalibur.event.impl.RateLimitingPredicate
accept(Object[], Sink) - Method in class org.apache.excalibur.event.impl.RateLimitingPredicate
accept(Object, Sink) - Method in class org.apache.excalibur.event.impl.ThresholdEnqueuePredicate: Returns true if the Sink size + 1 (the element) is less than the threshold.
accept(Object[], Sink) - Method in class org.apache.excalibur.event.impl.ThresholdEnqueuePredicate: Returns true if the Sink size + the number of elements is less than the threshold.
acquire() - Method in class org.apache.excalibur.mpool.BlockingFixedSizePool
acquire() - Method in class org.apache.excalibur.mpool.FixedSizePool
acquire() - Method in class org.apache.excalibur.mpool.VariableSizePool
addElement(Object) - Method in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
addPreparedEnqueue(PreparedEnqueue) - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink.DefaultPreparedEnqueue: Adds a prepared enqueue object to the list of prepared enqueues.
addPreparedEnqueue(PreparedEnqueue) - Method in class org.apache.excalibur.event.impl.MultiCastSink.DefaultPreparedEnqueue: Adds a prepared enqueue object to the list of prepared enqueues.
after(Source) - Method in class org.apache.excalibur.event.command.TPSPThreadManager.SourceDequeueInterceptor: An operation executed after dequeing events from the queue.
after(Source) - Method in class org.apache.excalibur.event.impl.NullDequeueInterceptor: An operation executed after dequeing events from the queue.
architecture() - Static method in class org.apache.excalibur.util.SystemUtil: Return the architecture name

B

before(Source) - Method in class org.apache.excalibur.event.command.TPSPThreadManager.SourceDequeueInterceptor: An operation executed before dequeing events from the queue.
before(Source) - Method in class org.apache.excalibur.event.impl.NullDequeueInterceptor: An operation executed before dequeing events from the queue.
block(Object) - Method in class org.apache.excalibur.event.impl.AbstractQueue: Encapsulates the logic to block the Queue for the amount of time specified by the timeout.
BlockingFixedSizePool - Class in org.apache.excalibur.mpool: This is an Pool that caches Poolable objects for reuse.
BlockingFixedSizePool(ObjectFactory, int) - Constructor for class org.apache.excalibur.mpool.BlockingFixedSizePool
BlockingFixedSizePool(ObjectFactory, int, long) - Constructor for class org.apache.excalibur.mpool.BlockingFixedSizePool

C

canAccept() - Method in class org.apache.excalibur.event.impl.AbstractQueue: Default for canAccept()
canAccept() - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
canAccept() - Method in class org.apache.excalibur.event.impl.MultiCastSink
CommandManager - Class in org.apache.excalibur.event.command: The CommandManager handles asynchronous commands from the rest of the system.
CommandManager() - Constructor for class org.apache.excalibur.event.command.CommandManager: Create the CommandManager
CommandManager.CommandEventHandler - Class in org.apache.excalibur.event.command
CommandManager.CommandEventHandler(Map) - Constructor for class org.apache.excalibur.event.command.CommandManager.CommandEventHandler
CommandManager.DelayedCommandInfo - Class in org.apache.excalibur.event.command
CommandManager.DelayedCommandInfo() - Constructor for class org.apache.excalibur.event.command.CommandManager.DelayedCommandInfo
commit() - Method in class org.apache.excalibur.event.impl.DefaultQueue.DefaultPreparedEnqueue
commit() - Method in class org.apache.excalibur.event.impl.FixedSizeQueue.FixedSizePreparedEnqueue: Deprecated.
commit() - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink.DefaultPreparedEnqueue
commit() - Method in class org.apache.excalibur.event.impl.MultiCastSink.DefaultPreparedEnqueue
cpuInfo() - Method in interface org.apache.excalibur.util.CPUParser: Return the cpu info for the processors (assuming symetric multiprocessing which means that all CPUs are identical).
cpuInfo() - Method in class org.apache.excalibur.util.system.Linux: Return the cpu info for the processors (assuming symetric multiprocessing which means that all CPUs are identical).
cpuInfo() - Method in class org.apache.excalibur.util.system.Windows2000: Return the cpu info for the processors (assuming symetric multiprocessing which means that all CPUs are identical).
cpuInfo() - Method in class org.apache.excalibur.util.system.Windows95: Return the cpu info for the processors (assuming symetric multiprocessing which means that all CPUs are identical).
cpuInfo() - Method in class org.apache.excalibur.util.system.Windows98: Return the cpu info for the processors (assuming symetric multiprocessing which means that all CPUs are identical).
cpuInfo() - Method in class org.apache.excalibur.util.system.WindowsNT: Return the cpu info for the processors (assuming symetric multiprocessing which means that all CPUs are identical).
cpuInfo() - Method in class org.apache.excalibur.util.system.WindowsXP: Return the cpu info for the processors (assuming symetric multiprocessing which means that all CPUs are identical).
cpuInfo() - Static method in class org.apache.excalibur.util.SystemUtil
CPUParser - Interface in org.apache.excalibur.util: This interface is for CPUParser objects that are automagically loaded, and perform architecture dependant processing for determining the number of CPUs, and the generic infomation about them.

D

DefaultPoolManager - Class in org.apache.excalibur.mpool: This interface is for a PoolManager that creates pools that are managed asynchronously.
DefaultPoolManager() - Constructor for class org.apache.excalibur.mpool.DefaultPoolManager
DefaultPoolManager(Sink) - Constructor for class org.apache.excalibur.mpool.DefaultPoolManager
DefaultPoolManager.PoolManagerCommand - Class in org.apache.excalibur.mpool
DefaultPoolManager.PoolManagerCommand(Map) - Constructor for class org.apache.excalibur.mpool.DefaultPoolManager.PoolManagerCommand
DefaultQueue - Class in org.apache.excalibur.event.impl: The default queue implementation is a variable size queue.
DefaultQueue(int) - Constructor for class org.apache.excalibur.event.impl.DefaultQueue: Construct a new DefaultQueue with the specified number of elements.
DefaultQueue(EnqueuePredicate) - Constructor for class org.apache.excalibur.event.impl.DefaultQueue
DefaultQueue() - Constructor for class org.apache.excalibur.event.impl.DefaultQueue: Create an unbounded DefaultQueue.
DefaultQueue.DefaultPreparedEnqueue - Class in org.apache.excalibur.event.impl
DefaultQueue.DefaultPreparedEnqueue(DefaultQueue, Object[]) - Constructor for class org.apache.excalibur.event.impl.DefaultQueue.DefaultPreparedEnqueue
DefaultThreadManager - Class in org.apache.excalibur.event.command: A ThreadManager that will use an external ThreadPool.
DefaultThreadManager(Executor) - Constructor for class org.apache.excalibur.event.command.DefaultThreadManager: Create a new ThreadManager with the associated ThreadPool.
dequeue(int) - Method in class org.apache.excalibur.event.impl.DefaultQueue
dequeue() - Method in class org.apache.excalibur.event.impl.DefaultQueue
dequeue(int) - Method in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
dequeue() - Method in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
dequeueAll() - Method in class org.apache.excalibur.event.impl.DefaultQueue
dequeueAll() - Method in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
deregister(EventPipeline) - Method in class org.apache.excalibur.event.command.AbstractThreadManager: Deregister an EventPipeline with the ThreadManager
deregister(EventPipeline) - Method in class org.apache.excalibur.event.command.TPSPThreadManager: Deregister an EventPipeline with the ThreadManager
deregisterAll() - Method in class org.apache.excalibur.event.command.AbstractThreadManager: Deregisters all EventPipelines from this ThreadManager
deregisterAll() - Method in class org.apache.excalibur.event.command.TPSPThreadManager: Deregisters all EventPipelines from this ThreadManager
deregisterSignalHandler(Signal, EventHandler) - Method in class org.apache.excalibur.event.command.CommandManager: Deregister a Signal with an EventHandler.
dispose() - Method in class org.apache.excalibur.event.command.AbstractThreadManager: Get rid of the ThreadManager.
dispose() - Method in class org.apache.excalibur.event.command.CommandManager: When you are done with CommandManager, call this and it will clean up all its resources.
dispose() - Method in class org.apache.excalibur.mpool.BlockingFixedSizePool
dispose() - Method in class org.apache.excalibur.mpool.FixedSizePool
dispose() - Method in class org.apache.excalibur.mpool.VariableSizePool
doDispose() - Method in class org.apache.excalibur.event.command.AbstractThreadManager
doDispose() - Method in class org.apache.excalibur.event.command.TPCThreadManager

E

EMPTY - Static variable in class org.apache.excalibur.mpool.PoolUtil
EMPTY_ARGS - Static variable in class org.apache.excalibur.mpool.PoolUtil
EMPTY_ARRAY - Static variable in class org.apache.excalibur.event.impl.AbstractQueue: An empty array used as a return value when the Queue is empty
enqueue(Object[]) - Method in class org.apache.excalibur.event.impl.DefaultQueue
enqueue(Object) - Method in class org.apache.excalibur.event.impl.DefaultQueue
enqueue(Object[]) - Method in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
enqueue(Object) - Method in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
enqueue(Object) - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
enqueue(Object[]) - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
enqueue(Object) - Method in class org.apache.excalibur.event.impl.MultiCastSink
enqueue(Object[]) - Method in class org.apache.excalibur.event.impl.MultiCastSink
execute() - Method in class org.apache.excalibur.mpool.DefaultPoolManager.PoolManagerCommand

F

FixedSizePool - Class in org.apache.excalibur.mpool: This is an Pool that caches Poolable objects for reuse.
FixedSizePool(ObjectFactory, int) - Constructor for class org.apache.excalibur.mpool.FixedSizePool
FixedSizeQueue - Class in org.apache.excalibur.event.impl: Deprecated.
Use the DefaultQueue as it properly supports the EnqueuePredicates
FixedSizeQueue(int) - Constructor for class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.

Create a FixedSizedQueue with the specified maximum size.
FixedSizeQueue.FixedSizePreparedEnqueue - Class in org.apache.excalibur.event.impl: Deprecated.
FixedSizeQueue.FixedSizePreparedEnqueue(FixedSizeQueue, Object[]) - Constructor for class org.apache.excalibur.event.impl.FixedSizeQueue.FixedSizePreparedEnqueue: Deprecated.

G

getBucketSize() - Method in class org.apache.excalibur.event.impl.RateLimitingPredicate: Returns the number of tokens currently in the bucket.
getCommandFailureHandler() - Method in class org.apache.excalibur.event.command.CommandManager: Get the failure handler so that CommandManager can use it when a problem happens.
getCommandSink() - Method in class org.apache.excalibur.event.command.CommandManager: Get the Command Sink so that you can enqueue new commands.
getDelayInterval() - Method in class org.apache.excalibur.mpool.DefaultPoolManager.PoolManagerCommand
getDepth() - Method in class org.apache.excalibur.event.impl.RateLimitingPredicate: Returns the current depth.
getDequeueInterceptor() - Method in class org.apache.excalibur.event.impl.AbstractQueue: Return the dequeue executable for this sink.
getEnqueuePredicate() - Method in class org.apache.excalibur.event.impl.AbstractQueue: Return the EnqueuePredicate that is already set for this Queue.
getEventHandler() - Method in class org.apache.excalibur.event.command.CommandManager: Used by the ThreadManager to get the EventHandler for the CommandManager.
getKey() - Method in class org.apache.excalibur.mpool.DefaultPoolManager: Return a new key for the pool and controller.
getManagedPool(ObjectFactory, int) - Method in class org.apache.excalibur.mpool.DefaultPoolManager: Return a managed pool that has a controller.
getNumberOfRepeats() - Method in class org.apache.excalibur.mpool.DefaultPoolManager.PoolManagerCommand
getRepeatInterval() - Method in class org.apache.excalibur.mpool.DefaultPoolManager.PoolManagerCommand
getSleepTime() - Method in class org.apache.excalibur.event.command.AbstractThreadManager: Get the current amount of sleep time.
getSource() - Method in class org.apache.excalibur.event.command.TPSPThreadManager.SourceRunner: Get a reference to the Source.
getSources() - Method in class org.apache.excalibur.event.command.CommandManager: Used by the Threadmanager to get the sources that are feeding the CommandManager.
getTargetRate() - Method in class org.apache.excalibur.event.impl.RateLimitingPredicate: Returns the current rate limit.
grow(int, long) - Method in class org.apache.excalibur.mpool.VariableSizePool

H

handleCommandFailure(Command, Throwable) - Method in class org.apache.excalibur.event.command.NullCommandFailureHandler: Handle a command failure.
handleEvent(Object) - Method in class org.apache.excalibur.event.command.CommandManager.CommandEventHandler
handleEvents(Object[]) - Method in class org.apache.excalibur.event.command.CommandManager.CommandEventHandler

I

initialize() - Method in class org.apache.excalibur.event.command.AbstractThreadManager: Set up the ThreadManager.
initialize() - Method in class org.apache.excalibur.event.command.TPCThreadManager
initialize() - Method in class org.apache.excalibur.mpool.BlockingFixedSizePool
isFull() - Method in class org.apache.excalibur.event.impl.AbstractQueue: Check to see if the Queue is full.
isFull() - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
isFull() - Method in class org.apache.excalibur.event.impl.MultiCastSink
isInitialized() - Method in class org.apache.excalibur.event.command.AbstractThreadManager: Return whether the thread manager has been initialized or not

L

Linux - Class in org.apache.excalibur.util.system: Parses the Linux environment--Uses the proc filesystem to determine all the CPU information.
Linux() - Constructor for class org.apache.excalibur.util.system.Linux
LossyMultiCastSink - Class in org.apache.excalibur.event.impl: This is a org.apache.excalibur.event.seda.event.Sink implementation that multicasts enqueue operations to the contained and concrete sink objects.
LossyMultiCastSink(Collection) - Constructor for class org.apache.excalibur.event.impl.LossyMultiCastSink: This constructor creates a failure tolerant sink based on the collection of sink arrays.
LossyMultiCastSink(Collection, boolean) - Constructor for class org.apache.excalibur.event.impl.LossyMultiCastSink: This constructor creates a failure tolerant sink based on the collection of sink arrays.
LossyMultiCastSink.DefaultPreparedEnqueue - Class in org.apache.excalibur.event.impl: A prepared enqueue object that holds other prepared enqueue objects and allows to perform a commit / abort on all of these objects.
LossyMultiCastSink.DefaultPreparedEnqueue() - Constructor for class org.apache.excalibur.event.impl.LossyMultiCastSink.DefaultPreparedEnqueue

M

m_architecture - Static variable in class org.apache.excalibur.util.SystemUtil
m_buffer - Variable in class org.apache.excalibur.mpool.BlockingFixedSizePool
m_buffer - Variable in class org.apache.excalibur.mpool.FixedSizePool
m_buffer - Variable in class org.apache.excalibur.mpool.VariableSizePool
m_command - Variable in class org.apache.excalibur.event.command.CommandManager.DelayedCommandInfo
m_cpuInfo - Variable in class org.apache.excalibur.util.system.Linux
m_cpuInfo - Variable in class org.apache.excalibur.util.system.Windows2000
m_cpuInfo - Variable in class org.apache.excalibur.util.system.Windows95
m_cpuInfo - Variable in class org.apache.excalibur.util.system.Windows98
m_cpuInfo - Variable in class org.apache.excalibur.util.system.WindowsNT
m_cpuInfo - Variable in class org.apache.excalibur.util.system.WindowsXP
m_cpuInfo - Static variable in class org.apache.excalibur.util.SystemUtil
m_delayedCommands - Variable in class org.apache.excalibur.event.command.CommandManager.CommandEventHandler
m_depth - Variable in class org.apache.excalibur.event.impl.RateLimitingPredicate: The depth of the token bucket
m_disposed - Variable in class org.apache.excalibur.mpool.BlockingFixedSizePool
m_disposed - Variable in class org.apache.excalibur.mpool.FixedSizePool
m_disposed - Variable in class org.apache.excalibur.mpool.VariableSizePool
m_done - Variable in class org.apache.excalibur.event.command.AbstractThreadManager: Whether we are done or not
m_elements - Variable in class org.apache.excalibur.event.impl.DefaultQueue.DefaultPreparedEnqueue
m_elements - Variable in class org.apache.excalibur.event.impl.DefaultQueue
m_elements - Variable in class org.apache.excalibur.event.impl.FixedSizeQueue.FixedSizePreparedEnqueue: Deprecated.
m_elements - Variable in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
m_end - Variable in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
m_eventHandler - Variable in class org.apache.excalibur.event.command.CommandManager
m_executor - Variable in class org.apache.excalibur.event.command.AbstractThreadManager: The ThreadPool we are using
m_factory - Variable in class org.apache.excalibur.mpool.BlockingFixedSizePool
m_factory - Variable in class org.apache.excalibur.mpool.FixedSizePool
m_factory - Variable in class org.apache.excalibur.mpool.VariableSizePool
m_factoryMap - Variable in class org.apache.excalibur.mpool.DefaultPoolManager
m_failureHandler - Variable in class org.apache.excalibur.event.command.CommandManager
m_grow - Variable in class org.apache.excalibur.mpool.DefaultPoolManager.PoolManagerCommand
m_handler - Variable in class org.apache.excalibur.event.command.TPSPThreadManager.SourceDequeueInterceptor
m_handler - Variable in class org.apache.excalibur.event.command.TPSPThreadManager.SourceRunner
m_hardShutdown - Variable in class org.apache.excalibur.event.command.TPCThreadManager
m_initialized - Variable in class org.apache.excalibur.event.command.AbstractThreadManager: Whether this class has been initialized or not
m_initRunner - Variable in class org.apache.excalibur.event.command.TPSPThreadManager.SourceDequeueInterceptor
m_interceptor - Variable in class org.apache.excalibur.event.impl.AbstractQueue
m_isAccepting - Variable in class org.apache.excalibur.event.command.CommandManager
m_keepAliveTime - Variable in class org.apache.excalibur.event.command.TPCThreadManager
m_keepProcessing - Variable in class org.apache.excalibur.event.command.TPSPThreadManager.SourceRunner
m_key - Variable in class org.apache.excalibur.mpool.VariableSizePool
m_keyGenerator - Variable in class org.apache.excalibur.mpool.DefaultPoolManager
m_keyMap - Variable in class org.apache.excalibur.mpool.DefaultPoolManager
m_lastTime - Variable in class org.apache.excalibur.event.impl.RateLimitingPredicate
m_map - Variable in class org.apache.excalibur.mpool.DefaultPoolManager.PoolManagerCommand
m_margin - Variable in class org.apache.excalibur.event.command.TPSPThreadManager
m_margin - Variable in class org.apache.excalibur.event.command.TPSPThreadManager.SourceDequeueInterceptor
m_max - Variable in class org.apache.excalibur.mpool.DefaultPoolManager.PoolManagerCommand
m_maxSize - Variable in class org.apache.excalibur.event.impl.DefaultQueue
m_maxSize - Variable in class org.apache.excalibur.mpool.BlockingFixedSizePool
m_maxThreadsPerPool - Variable in class org.apache.excalibur.event.command.TPSPThreadManager
m_min - Variable in class org.apache.excalibur.mpool.DefaultPoolManager.PoolManagerCommand
m_mutex - Variable in class org.apache.excalibur.event.command.CommandManager
m_mutex - Variable in class org.apache.excalibur.event.impl.DefaultQueue
m_mutex - Variable in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
m_nextRunTime - Variable in class org.apache.excalibur.event.command.CommandManager.DelayedCommandInfo
m_numExecutions - Variable in class org.apache.excalibur.event.command.CommandManager.DelayedCommandInfo
m_oneSuccess - Variable in class org.apache.excalibur.event.impl.LossyMultiCastSink: indicates if at least one enqueue operation must succeed.
m_osName - Static variable in class org.apache.excalibur.util.SystemUtil
m_osVersion - Static variable in class org.apache.excalibur.util.SystemUtil
m_parent - Variable in class org.apache.excalibur.event.command.TPSPThreadManager.SourceDequeueInterceptor
m_parent - Variable in class org.apache.excalibur.event.impl.DefaultQueue.DefaultPreparedEnqueue
m_parent - Variable in class org.apache.excalibur.event.impl.FixedSizeQueue.FixedSizePreparedEnqueue: Deprecated.
m_pipeline - Variable in class org.apache.excalibur.event.command.AbstractThreadManager.PipelineRunner: The pipeline we are managing
m_pipelines - Variable in class org.apache.excalibur.event.command.AbstractThreadManager: The pipelines we are managing
m_pipelines - Variable in class org.apache.excalibur.event.command.TPSPThreadManager
m_predicate - Variable in class org.apache.excalibur.event.impl.AbstractQueue
m_preparedEnqueues - Variable in class org.apache.excalibur.event.impl.LossyMultiCastSink.DefaultPreparedEnqueue: A collection of prepared enqueue objects
m_preparedEnqueues - Variable in class org.apache.excalibur.event.impl.MultiCastSink.DefaultPreparedEnqueue: A collection of prepared enqueue objects
m_processors - Variable in class org.apache.excalibur.event.command.TPCThreadManager
m_processors - Variable in class org.apache.excalibur.util.system.Linux
m_processors - Variable in class org.apache.excalibur.util.system.Windows2000
m_processors - Variable in class org.apache.excalibur.util.system.Windows95
m_processors - Variable in class org.apache.excalibur.util.system.Windows98
m_processors - Variable in class org.apache.excalibur.util.system.WindowsNT
m_processors - Variable in class org.apache.excalibur.util.system.WindowsXP
m_processors - Static variable in class org.apache.excalibur.util.SystemUtil
m_queue - Variable in class org.apache.excalibur.event.command.CommandManager
m_regenTimeMs - Variable in class org.apache.excalibur.event.impl.RateLimitingPredicate
m_repeatable - Variable in class org.apache.excalibur.event.command.CommandManager.DelayedCommandInfo
m_reserve - Variable in class org.apache.excalibur.event.impl.DefaultQueue
m_reserve - Variable in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
m_runners - Variable in class org.apache.excalibur.event.command.TPSPThreadManager.SourceDequeueInterceptor
m_semaphore - Variable in class org.apache.excalibur.mpool.BlockingFixedSizePool: The semaphor we synchronize on
m_signalHandlers - Variable in class org.apache.excalibur.event.command.CommandManager.CommandEventHandler
m_signalHandlers - Variable in class org.apache.excalibur.event.command.CommandManager
m_single - Variable in class org.apache.excalibur.event.impl.MultiCastSink: Boolean value describing if one or all operations must succeed.
m_sinks - Variable in class org.apache.excalibur.event.impl.LossyMultiCastSink: A collection of sink arrays representing the sinks to enqueue the element to.
m_sinks - Variable in class org.apache.excalibur.event.impl.MultiCastSink: A collection of sink arrays representing the sinks to enqueue to.
m_size - Variable in class org.apache.excalibur.event.impl.LossyMultiCastSink: The size of the sink.
m_size - Variable in class org.apache.excalibur.event.impl.MultiCastSink: The size of the sink.
m_sleepTime - Variable in class org.apache.excalibur.event.command.AbstractThreadManager: The number of milliseconds to sleep before runngin again: 1000 (1 sec.)
m_source - Variable in class org.apache.excalibur.event.command.TPSPThreadManager.SourceDequeueInterceptor
m_source - Variable in class org.apache.excalibur.event.command.TPSPThreadManager.SourceRunner
m_sources - Variable in class org.apache.excalibur.event.command.CommandManager
m_start - Variable in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
m_targetRate - Variable in class org.apache.excalibur.event.impl.RateLimitingPredicate: The rate to which the enqueuing should be limited
m_threadPool - Variable in class org.apache.excalibur.event.command.TPCThreadManager
m_threadPool - Variable in class org.apache.excalibur.event.command.TPSPThreadManager.SourceDequeueInterceptor
m_threadsPerProcessor - Variable in class org.apache.excalibur.event.command.TPCThreadManager
m_threshold - Variable in class org.apache.excalibur.event.command.TPSPThreadManager
m_threshold - Variable in class org.apache.excalibur.event.command.TPSPThreadManager.SourceDequeueInterceptor
m_threshold - Variable in class org.apache.excalibur.event.impl.ThresholdEnqueuePredicate
m_timeout - Variable in class org.apache.excalibur.event.impl.AbstractQueue: The number of milliseconds to wait
m_timeout - Variable in class org.apache.excalibur.mpool.BlockingFixedSizePool
m_tokenCount - Variable in class org.apache.excalibur.event.impl.RateLimitingPredicate
maxSize() - Method in class org.apache.excalibur.event.impl.AbstractQueue: Default maxSize to -1 which is unbounded
maxSize() - Method in class org.apache.excalibur.event.impl.DefaultQueue: Return the maximum number of elements that will fit in the Queue.
maxSize() - Method in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
maxSize() - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
maxSize() - Method in class org.apache.excalibur.event.impl.MultiCastSink
MIN_REGENERATION_TIME - Static variable in class org.apache.excalibur.event.impl.RateLimitingPredicate: Number of milliseconds between regenerations
MultiCastSink - Class in org.apache.excalibur.event.impl: This is a org.apache.excalibur.event.seda.event.Sink implementation that multicasts enqueue operations to the contained and concrete sink objects.
MultiCastSink(Collection) - Constructor for class org.apache.excalibur.event.impl.MultiCastSink: This constructor creates a failure in-tolerant multicast sink based on the collection of sink arrays.
MultiCastSink(Collection, boolean) - Constructor for class org.apache.excalibur.event.impl.MultiCastSink: This constructor creates a failure in-tolerant multicast sink based on the collection of sink arrays.
MultiCastSink.DefaultPreparedEnqueue - Class in org.apache.excalibur.event.impl: A prepared enqueue object that holds other prepared enqueue objects and allows to perform a commit / abort on all of these objects.
MultiCastSink.DefaultPreparedEnqueue() - Constructor for class org.apache.excalibur.event.impl.MultiCastSink.DefaultPreparedEnqueue

N

newInstance() - Method in class org.apache.excalibur.mpool.BlockingFixedSizePool
newInstance() - Method in class org.apache.excalibur.mpool.FixedSizePool
newInstance() - Method in class org.apache.excalibur.mpool.VariableSizePool
NullCommandFailureHandler - Class in org.apache.excalibur.event.command: NullCommandFailureHandler is used to do nothing if a command fails.
NullCommandFailureHandler() - Constructor for class org.apache.excalibur.event.command.NullCommandFailureHandler
NullDequeueInterceptor - Class in org.apache.excalibur.event.impl: The dequeue executable interface describes operations that are executed before and after elements are pulled from a queue.
NullDequeueInterceptor() - Constructor for class org.apache.excalibur.event.impl.NullDequeueInterceptor
NullEnqueuePredicate - Class in org.apache.excalibur.event.impl: The NullEnqueuePredicate does nothing to limit a Queue's ability to enqueue.
NullEnqueuePredicate() - Constructor for class org.apache.excalibur.event.impl.NullEnqueuePredicate
numProcessors() - Method in interface org.apache.excalibur.util.CPUParser: Return the number of processors available on the machine
numProcessors() - Method in class org.apache.excalibur.util.system.Linux: Return the number of processors available on the machine
numProcessors() - Method in class org.apache.excalibur.util.system.Windows2000: Return the number of processors available on the machine
numProcessors() - Method in class org.apache.excalibur.util.system.Windows95: Return the number of processors available on the machine
numProcessors() - Method in class org.apache.excalibur.util.system.Windows98: Return the number of processors available on the machine
numProcessors() - Method in class org.apache.excalibur.util.system.WindowsNT: Return the number of processors available on the machine
numProcessors() - Method in class org.apache.excalibur.util.system.WindowsXP: Return the number of processors available on the machine
numProcessors() - Static method in class org.apache.excalibur.util.SystemUtil: Return the number of processors available on this machine.

O

operatingSystem() - Static method in class org.apache.excalibur.util.SystemUtil: Return the Operating System name
org.apache.excalibur.event.command - package org.apache.excalibur.event.command
org.apache.excalibur.event.impl - package org.apache.excalibur.event.impl
org.apache.excalibur.mpool - package org.apache.excalibur.mpool
org.apache.excalibur.util - package org.apache.excalibur.util
org.apache.excalibur.util.system - package org.apache.excalibur.util.system
osVersion() - Static method in class org.apache.excalibur.util.SystemUtil: Return the Operating System version

P

parameterize(Parameters) - Method in class org.apache.excalibur.event.command.TPCThreadManager: The following parameters can be set for this class: Name Description Default Value processors Number of processors (autodetected if less than one) Results from SystemUtil.numProcessors() threads-per-processor Threads per processor to use (Rewritten to 1 if less than one) 1 sleep-time Time (in milliseconds) to wait between queue pipeline processing runs 1000 keep-alive-time Time (in milliseconds) that idle threads should remain in the threadpool 300000 force-shutdown At shutdown time, allow currently queued tasks to finish, or immediately quit false
PoolUtil - Class in org.apache.excalibur.mpool: The PoolUtil class performs the reflection magic that is necessary to work with the legacy Recyclable interface in the Pool package.
PoolUtil() - Constructor for class org.apache.excalibur.mpool.PoolUtil
prepareEnqueue(Object[]) - Method in class org.apache.excalibur.event.impl.DefaultQueue
prepareEnqueue(Object[]) - Method in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
prepareEnqueue(Object[]) - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
prepareEnqueue(Object[]) - Method in class org.apache.excalibur.event.impl.MultiCastSink

R

RateLimitingPredicate - Class in org.apache.excalibur.event.impl: This enqueue predicate implements input rate policing.
RateLimitingPredicate(int) - Constructor for class org.apache.excalibur.event.impl.RateLimitingPredicate: Create a new RateLimitingPredicate for the given sink, bucket depth and no rate limit.
RateLimitingPredicate(double, int) - Constructor for class org.apache.excalibur.event.impl.RateLimitingPredicate: Create a new RateLimitingPredicate for the given sink, targetRate, and token bucket depth.
recycle(Object) - Static method in class org.apache.excalibur.mpool.PoolUtil: This method will either call "reset" on Resettable objects, or it will call "recycle" on Recyclable objects.
recycleLegacy(Object) - Static method in class org.apache.excalibur.mpool.PoolUtil
register(EventPipeline) - Method in class org.apache.excalibur.event.command.AbstractThreadManager: Register an EventPipeline with the ThreadManager.
register(EventPipeline) - Method in class org.apache.excalibur.event.command.TPSPThreadManager: Register an EventPipeline with the ThreadManager.
registerSignalHandler(Signal, EventHandler) - Method in class org.apache.excalibur.event.command.CommandManager: Register a Signal with an EventHandler.
release(Object) - Method in class org.apache.excalibur.mpool.BlockingFixedSizePool
release(Object) - Method in class org.apache.excalibur.mpool.FixedSizePool
release(Object) - Method in class org.apache.excalibur.mpool.VariableSizePool
removeElement() - Method in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
retrieveElements(Buffer, int) - Static method in class org.apache.excalibur.event.impl.DefaultQueue: Removes the given number of elements from the given buf and returns them in an array.
retrieveElements(int) - Method in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.

Removes exactly count elements from the underlying element store and returns them as an array of Objects.
run() - Method in class org.apache.excalibur.event.command.AbstractThreadManager.PipelineRunner: The code that actually pulls the events from the Sources and sends them to the event handler
run() - Method in class org.apache.excalibur.event.command.AbstractThreadManager: The code that is run in the background to manage the ThreadPool and the EventPipelines
run() - Method in class org.apache.excalibur.event.command.TPSPThreadManager.SourceRunner: Called by the PooledExecutor to ensure all components are working.

S

setCommandFailureHandler(CommandFailureHandler) - Method in class org.apache.excalibur.event.command.CommandManager: Set the failure handler that the application can use to override what happens when a command failure happens.
setDepth(int) - Method in class org.apache.excalibur.event.impl.RateLimitingPredicate: Allows to set the bucket depth.
setDequeueInterceptor(DequeueInterceptor) - Method in class org.apache.excalibur.event.impl.AbstractQueue: Set the dequeue executable for this sink.
setEnqueuePredicate(EnqueuePredicate) - Method in class org.apache.excalibur.event.impl.AbstractQueue: Set the EnqueuePredicate to limit entries into this Queue.
setExecutor(Executor) - Method in class org.apache.excalibur.event.command.AbstractThreadManager: Set the executor we are using
setSleepTime(long) - Method in class org.apache.excalibur.event.command.AbstractThreadManager: Set the amount of time to sleep between checks on the queue
setTargetRate(double) - Method in class org.apache.excalibur.event.impl.RateLimitingPredicate: Allows to set the rate limit.
setTimeout(long) - Method in class org.apache.excalibur.event.impl.AbstractQueue: Set the timeout for the Queue in milliseconds.
SHARED_INSTANCE - Static variable in class org.apache.excalibur.event.command.NullCommandFailureHandler
shrink(int, long) - Method in class org.apache.excalibur.mpool.VariableSizePool
size() - Method in class org.apache.excalibur.event.impl.DefaultQueue: Return the number of elements currently in the Queue.
size() - Method in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
size() - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
size() - Method in class org.apache.excalibur.event.impl.MultiCastSink
size(long) - Method in class org.apache.excalibur.mpool.VariableSizePool
split(String, String) - Static method in class org.apache.excalibur.util.system.Linux: Splits the string on every token into an array of strings.
stop() - Method in class org.apache.excalibur.event.command.TPSPThreadManager.SourceDequeueInterceptor: Ensure all event runners are stopped for this partial pipeline.
stop() - Method in class org.apache.excalibur.event.command.TPSPThreadManager.SourceRunner: Stop the runner nicely.
stripWhitespace(String) - Static method in class org.apache.excalibur.util.SystemUtil: Utility method to strip whitespace from specified name.
SystemUtil - Class in org.apache.excalibur.util: A set of utility operations that provide necessary information about the architecture of the machine that the system is running on.
SystemUtil() - Constructor for class org.apache.excalibur.util.SystemUtil: keep utility from being instantiated

T

ThresholdEnqueuePredicate - Class in org.apache.excalibur.event.impl: The ThresholdEnqueuePredicate limits the elements that can be enqueued based on the size of the Queue.
ThresholdEnqueuePredicate(int) - Constructor for class org.apache.excalibur.event.impl.ThresholdEnqueuePredicate: Create a new ThresholdEnqueuePredicate with the supplied limit.
TPCThreadManager - Class in org.apache.excalibur.event.command: This is a ThreadManager that uses a certain number of threads per processor.
TPCThreadManager() - Constructor for class org.apache.excalibur.event.command.TPCThreadManager
TPSPThreadManager - Class in org.apache.excalibur.event.command: This is a ThreadManager which provides a threadpool per Sink per EventPipeline.
TPSPThreadManager() - Constructor for class org.apache.excalibur.event.command.TPSPThreadManager: The default constructor assumes there is a system property named "os.arch.cpus" that has a default for the number of CPUs on a system.
TPSPThreadManager(int, int) - Constructor for class org.apache.excalibur.event.command.TPSPThreadManager: Constructor provides a specified number of threads per processor.
TPSPThreadManager(int, int, int) - Constructor for class org.apache.excalibur.event.command.TPSPThreadManager: Constructor provides a specified number of threads per processor.
TPSPThreadManager.SourceDequeueInterceptor - Class in org.apache.excalibur.event.command: This is used to plug into Queues so that we can intercept calls to the dequeue operation.
TPSPThreadManager.SourceDequeueInterceptor(TPSPThreadManager.SourceRunner, EventHandler, PooledExecutor, int, int) - Constructor for class org.apache.excalibur.event.command.TPSPThreadManager.SourceDequeueInterceptor: Create a new SourceDequeueInterceptor.
TPSPThreadManager.SourceRunner - Class in org.apache.excalibur.event.command: The SourceRunner is used to dequeue events one at a time.
TPSPThreadManager.SourceRunner(Source, EventHandler) - Constructor for class org.apache.excalibur.event.command.TPSPThreadManager.SourceRunner: Create a new SourceRunner.
tryEnqueue(Object) - Method in class org.apache.excalibur.event.impl.DefaultQueue
tryEnqueue(Object) - Method in class org.apache.excalibur.event.impl.FixedSizeQueue: Deprecated.
tryEnqueue(Object) - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
tryEnqueue(Object) - Method in class org.apache.excalibur.event.impl.MultiCastSink

V

VariableSizePool - Class in org.apache.excalibur.mpool: This is an Pool that caches Poolable objects for reuse.
VariableSizePool(ObjectFactory, int) - Constructor for class org.apache.excalibur.mpool.VariableSizePool: Constructor for an unmanaged pool
VariableSizePool(ObjectFactory, int, long) - Constructor for class org.apache.excalibur.mpool.VariableSizePool: Constructor for a managed pool

W

Windows2000 - Class in org.apache.excalibur.util.system: Parses the Windows 2000 environment--the same class should work for other Windows versions, but I only have one to test.
Windows2000() - Constructor for class org.apache.excalibur.util.system.Windows2000
Windows95 - Class in org.apache.excalibur.util.system: Parses the Windows 95 environment--the same class should work for other Windows versions, but I only have one to test.
Windows95() - Constructor for class org.apache.excalibur.util.system.Windows95
Windows98 - Class in org.apache.excalibur.util.system: Parses the Windows 98 environment--the same class should work for other Windows versions, but I only have one to test.
Windows98() - Constructor for class org.apache.excalibur.util.system.Windows98
WindowsNT - Class in org.apache.excalibur.util.system: Parses the Windows 2000 environment--the same class should work for other Windows versions, but I only have one to test.
WindowsNT() - Constructor for class org.apache.excalibur.util.system.WindowsNT
WindowsXP - Class in org.apache.excalibur.util.system: Parses the Windows XP environment.
WindowsXP() - Constructor for class org.apache.excalibur.util.system.WindowsXP: Create this instance of CPUParser and gather information from the Windows XP system.

Y

yield() - Static method in class org.apache.excalibur.event.command.TPSPThreadManager.SourceRunner: A way to make sure we yield the processor up to the next thread.

A B C D E F G H I L M N O P R S T V W Y