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