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

A

abort() - Method in interface org.apache.excalibur.event.PreparedEnqueue
Abort a previously prepared provisional enqueue operation (from the prepareEnqueue method).
AbstractQueue - class org.apache.excalibur.event.impl.AbstractQueue.
Provides the base functionality for the other Queue types.
AbstractQueue() - Constructor for class org.apache.excalibur.event.impl.AbstractQueue
 
AbstractThreadManager - class org.apache.excalibur.event.command.AbstractThreadManager.
Abstract base class for a ThreadManager that has a single ThreadPool for all pipelines
AbstractThreadManager.PipelineRunner - class org.apache.excalibur.event.command.AbstractThreadManager.PipelineRunner.
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.
AbstractThreadManager() - Constructor for class org.apache.excalibur.event.command.AbstractThreadManager
 
accept(Object[], Sink) - Method in interface org.apache.excalibur.event.EnqueuePredicate
Tests the given element for acceptance onto the m_sink.
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.
accept(Object[], Sink) - Method in class org.apache.excalibur.event.impl.RateLimitingPredicate
 
accept(Object[], Sink) - Method in class org.apache.excalibur.event.impl.NullEnqueuePredicate
 
accept(Object, Sink) - Method in interface org.apache.excalibur.event.EnqueuePredicate
Tests the given element for acceptance onto the m_sink.
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.RateLimitingPredicate
 
accept(Object, Sink) - Method in class org.apache.excalibur.event.impl.NullEnqueuePredicate
 
acquire() - Method in class org.apache.excalibur.mpool.VariableSizePool
 
acquire() - Method in interface org.apache.excalibur.mpool.Pool
Acquire an instance of the pooled object.
acquire() - Method in class org.apache.excalibur.mpool.FixedSizePool
 
acquire() - Method in class org.apache.excalibur.mpool.BlockingFixedSizePool
 
after(Source) - Method in interface org.apache.excalibur.event.DequeueInterceptor
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
attach(Object) - Method in interface org.apache.excalibur.event.Message
Attach an Object to the message.

B

before(Source) - Method in interface org.apache.excalibur.event.DequeueInterceptor
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 org.apache.excalibur.mpool.BlockingFixedSizePool.
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 interface org.apache.excalibur.event.Sink
Deprecated. Use the EnqueuePredicate to control this instead.
canAccept() - Method in class org.apache.excalibur.event.impl.MultiCastSink
 
canAccept() - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
 
canAccept() - Method in class org.apache.excalibur.event.impl.AbstractQueue
Default for canAccept()
clear() - Method in interface org.apache.excalibur.event.Message
Clear the attachment.
Command - interface org.apache.excalibur.event.command.Command.
A Command is a specific type of Signal that denotes an asynchronous execution unit that must be performed by the CommandManager.
CommandManager - class org.apache.excalibur.event.command.CommandManager.
The CommandManager handles asynchronous commands from the rest of the system.
CommandManager() - Constructor for class org.apache.excalibur.event.command.CommandManager
Create the CommandManager
commit() - Method in interface org.apache.excalibur.event.PreparedEnqueue
Commit a previously prepared provisional enqueue operation (from the prepareEnqueue method).
cpuInfo() - Static method in class org.apache.excalibur.util.SystemUtil
 
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.WindowsXP
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.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.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.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.Linux
Return the cpu info for the processors (assuming symetric multiprocessing which means that all CPUs are identical).
CPUParser - interface org.apache.excalibur.util.CPUParser.
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 org.apache.excalibur.mpool.DefaultPoolManager.
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
 
DefaultQueue - class org.apache.excalibur.event.impl.DefaultQueue.
The default queue implementation is a variable size queue.
DefaultQueue() - Constructor for class org.apache.excalibur.event.impl.DefaultQueue
Create an unbounded DefaultQueue.
DefaultQueue(EnqueuePredicate) - Constructor for class org.apache.excalibur.event.impl.DefaultQueue
 
DefaultQueue(int) - Constructor for class org.apache.excalibur.event.impl.DefaultQueue
Construct a new DefaultQueue with the specified number of elements.
DefaultThreadManager - class org.apache.excalibur.event.command.DefaultThreadManager.
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.
DelayedCommand - interface org.apache.excalibur.event.command.DelayedCommand.
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 interface org.apache.excalibur.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() - Method in class org.apache.excalibur.event.impl.FixedSizeQueue
Deprecated.  
dequeue() - Method in class org.apache.excalibur.event.impl.DefaultQueue
 
dequeue(int) - Method in interface org.apache.excalibur.event.Source
Dequeues at most num available elements.
dequeue(int) - Method in class org.apache.excalibur.event.impl.FixedSizeQueue
Deprecated.  
dequeue(int) - Method in class org.apache.excalibur.event.impl.DefaultQueue
 
dequeueAll() - Method in interface org.apache.excalibur.event.Source
Dequeues all available elements.
dequeueAll() - Method in class org.apache.excalibur.event.impl.FixedSizeQueue
Deprecated.  
dequeueAll() - Method in class org.apache.excalibur.event.impl.DefaultQueue
 
DequeueInterceptor - interface org.apache.excalibur.event.DequeueInterceptor.
The dequeue executable interface describes operations that are executed before and after elements are pulled from a queue.
deregister(EventPipeline) - Method in class org.apache.excalibur.event.command.TPSPThreadManager
Deregister an EventPipeline with the ThreadManager
deregister(EventPipeline) - Method in interface org.apache.excalibur.event.command.ThreadManager
Deregister an EventPipeline with the ThreadManager
deregister(EventPipeline) - Method in class org.apache.excalibur.event.command.AbstractThreadManager
Deregister an EventPipeline with the ThreadManager
deregisterAll() - Method in class org.apache.excalibur.event.command.TPSPThreadManager
Deregisters all EventPipelines from this ThreadManager
deregisterAll() - Method in interface org.apache.excalibur.event.command.ThreadManager
Deregisters all EventPipelines from this ThreadManager
deregisterAll() - Method in class org.apache.excalibur.event.command.AbstractThreadManager
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.CommandManager
When you are done with CommandManager, call this and it will clean up all its resources.
dispose() - Method in class org.apache.excalibur.event.command.AbstractThreadManager
Get rid of the ThreadManager.
dispose() - Method in class org.apache.excalibur.mpool.VariableSizePool
 
dispose() - Method in class org.apache.excalibur.mpool.FixedSizePool
 
dispose() - Method in class org.apache.excalibur.mpool.BlockingFixedSizePool
 
dispose(Object) - Method in interface org.apache.excalibur.mpool.ObjectFactory
Performs any deconstruction that is necessary for the object.
doDispose() - Method in class org.apache.excalibur.event.command.TPCThreadManager
 
doDispose() - Method in class org.apache.excalibur.event.command.AbstractThreadManager
 

E

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 interface org.apache.excalibur.event.Sink
Enqueues the given element onto the Sink.
enqueue(Object) - Method in class org.apache.excalibur.event.impl.MultiCastSink
 
enqueue(Object) - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
 
enqueue(Object) - Method in class org.apache.excalibur.event.impl.FixedSizeQueue
Deprecated.  
enqueue(Object) - Method in class org.apache.excalibur.event.impl.DefaultQueue
 
enqueue(Object[]) - Method in interface org.apache.excalibur.event.Sink
Given an array of elements, atomically enqueues all of the elements in the array.
enqueue(Object[]) - Method in class org.apache.excalibur.event.impl.MultiCastSink
 
enqueue(Object[]) - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
 
enqueue(Object[]) - Method in class org.apache.excalibur.event.impl.FixedSizeQueue
Deprecated.  
enqueue(Object[]) - Method in class org.apache.excalibur.event.impl.DefaultQueue
 
EnqueuePredicate - interface org.apache.excalibur.event.EnqueuePredicate.
Enqueue predicates allow users to specify a method that will 'screen' elements being enqueued onto a sink, either accepting or rejecting them.
EventHandler - interface org.apache.excalibur.event.EventHandler.
An EventHandler takes care of processing specific events in an event-based architecture.
EventPipeline - interface org.apache.excalibur.event.command.EventPipeline.
An EventPipeline is used by the ThreadManager to manage the event Queue and EventHandler relationship.

F

FixedSizePool - class org.apache.excalibur.mpool.FixedSizePool.
This is an Pool that caches Poolable objects for reuse.
FixedSizePool(ObjectFactory, int) - Constructor for class org.apache.excalibur.mpool.FixedSizePool
 
FixedSizeQueue - class org.apache.excalibur.event.impl.FixedSizeQueue.
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.

G

getAttachment() - Method in interface org.apache.excalibur.event.Message
Get the attachment associated with this Message.
getBucketSize() - Method in class org.apache.excalibur.event.impl.RateLimitingPredicate
Returns the number of tokens currently in the bucket.
getCause() - Method in class org.apache.excalibur.event.SinkException
Retrieve root cause of the exception.
getCommandSink() - Method in class org.apache.excalibur.event.command.CommandManager
Get the Command Sink so that you can enqueue new commands.
getCreatedClass() - Method in interface org.apache.excalibur.mpool.ObjectFactory
Get the class of the object you are creating.
getDelayInterval() - Method in interface org.apache.excalibur.event.command.DelayedCommand
Sets the initial delay for the Command.
getDepth() - Method in class org.apache.excalibur.event.impl.RateLimitingPredicate
Returns the current depth.
getDequeueInterceptor() - Method in interface org.apache.excalibur.event.Queue
Return the dequeue executable for this sink.
getDequeueInterceptor() - Method in class org.apache.excalibur.event.impl.AbstractQueue
Return the dequeue executable for this sink.
getEnqueuePredicate() - Method in interface org.apache.excalibur.event.Queue
Return the enqueue predicate 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 interface org.apache.excalibur.event.command.EventPipeline
Returns the reference to the EventHandler that the events from all the Sinks get merged into.
getEventHandler() - Method in class org.apache.excalibur.event.command.CommandManager
Used by the ThreadManager to get the EventHandler for the CommandManager.
getManagedPool(ObjectFactory, int) - Method in interface org.apache.excalibur.mpool.PoolManager
Return a managed pool that has a controller.
getManagedPool(ObjectFactory, int) - Method in class org.apache.excalibur.mpool.DefaultPoolManager
Return a managed pool that has a controller.
getNumberOfRepeats() - Method in interface org.apache.excalibur.event.command.RepeatedCommand
If the value is less than 1 (0 or negative), the command repeats for as long as the CommandManager is running.
getRepeatInterval() - Method in interface org.apache.excalibur.event.command.RepeatedCommand
Gets the repeat interval so that the CommandQueue keeps it for the specified amount of time before enqueuing it again.
getSleepTime() - Method in class org.apache.excalibur.event.command.AbstractThreadManager
Get the current amount of sleep time.
getSources() - Method in interface org.apache.excalibur.event.command.EventPipeline
There can be many different sources to merge into a pipeline.
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
 
grow(int, long) - Method in interface org.apache.excalibur.mpool.ManagablePool
Grow by the specified amount.

H

handleEvent(Object) - Method in interface org.apache.excalibur.event.EventHandler
Handle one event at a time.
handleEvents(Object[]) - Method in interface org.apache.excalibur.event.EventHandler
Handle a whole array of events at a time.

I

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

L

Linux - class org.apache.excalibur.util.system.Linux.
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 org.apache.excalibur.event.impl.LossyMultiCastSink.
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.

M

m_interceptor - Variable in class org.apache.excalibur.event.impl.AbstractQueue
 
m_predicate - Variable in class org.apache.excalibur.event.impl.AbstractQueue
 
m_reserve - Variable in class org.apache.excalibur.event.impl.FixedSizeQueue
Deprecated.  
m_reserve - Variable in class org.apache.excalibur.event.impl.DefaultQueue
 
m_semaphore - Variable in class org.apache.excalibur.mpool.BlockingFixedSizePool
The semaphor we synchronize on
m_timeout - Variable in class org.apache.excalibur.event.impl.AbstractQueue
The number of milliseconds to wait
ManagablePool - interface org.apache.excalibur.mpool.ManagablePool.
This is the interface for Pools that are not a fixed size.
maxSize() - Method in interface org.apache.excalibur.event.Sink
Deprecated. Use the EnqueuePredicate to control this instead.
maxSize() - Method in class org.apache.excalibur.event.impl.MultiCastSink
 
maxSize() - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
 
maxSize() - Method in class org.apache.excalibur.event.impl.FixedSizeQueue
Deprecated.  
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.AbstractQueue
Default maxSize to -1 which is unbounded
Message - interface org.apache.excalibur.event.Message.
A Source implements the side of an event queue where queue elements are dequeued operations only.
MultiCastSink - class org.apache.excalibur.event.impl.MultiCastSink.
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.

N

newInstance() - Method in class org.apache.excalibur.mpool.VariableSizePool
 
newInstance() - Method in interface org.apache.excalibur.mpool.Pool
Create a new instance of the object being pooled.
newInstance() - Method in interface org.apache.excalibur.mpool.ObjectFactory
Create a new instance of the object being pooled.
newInstance() - Method in class org.apache.excalibur.mpool.FixedSizePool
 
newInstance() - Method in class org.apache.excalibur.mpool.BlockingFixedSizePool
 
NullDequeueInterceptor - class org.apache.excalibur.event.impl.NullDequeueInterceptor.
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 org.apache.excalibur.event.impl.NullEnqueuePredicate.
The NullEnqueuePredicate does nothing to limit a Queue's ability to enqueue.
NullEnqueuePredicate() - Constructor for class org.apache.excalibur.event.impl.NullEnqueuePredicate
 
numProcessors() - Static method in class org.apache.excalibur.util.SystemUtil
Return the number of processors available on this machine.
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.WindowsXP
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.Windows98
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.Windows2000
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

O

ObjectFactory - interface org.apache.excalibur.mpool.ObjectFactory.
This interface is to define how an ObjectFactory is defined.
operatingSystem() - Static method in class org.apache.excalibur.util.SystemUtil
Return the Operating System name
org.apache.excalibur.event - package org.apache.excalibur.event
 
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 block-timeout Time (in milliseconds) to wait for a thread to process a pipeline 1000
Pool - interface org.apache.excalibur.mpool.Pool.
This interface is to define how a Pool is used.
PoolManager - interface org.apache.excalibur.mpool.PoolManager.
This interface is for a PoolManager that creates pools that are managed asynchronously.
PoolUtil - class org.apache.excalibur.mpool.PoolUtil.
The PoolUtil class performs the reflection magic that is necessary to work with the legacy Recyclable interface in the Pool package.
PreparedEnqueue - interface org.apache.excalibur.event.PreparedEnqueue.
A PreparedEnqueue is an object returned from a prepareEnqueue method that allows you to either commit or abort the enqueue operation.
prepareEnqueue(Object[]) - Method in interface org.apache.excalibur.event.Sink
Support for transactional enqueue.
prepareEnqueue(Object[]) - Method in class org.apache.excalibur.event.impl.MultiCastSink
 
prepareEnqueue(Object[]) - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
 
prepareEnqueue(Object[]) - Method in class org.apache.excalibur.event.impl.FixedSizeQueue
Deprecated.  
prepareEnqueue(Object[]) - Method in class org.apache.excalibur.event.impl.DefaultQueue
 

Q

Queue - interface org.apache.excalibur.event.Queue.
A Source implements the side of an event queue where QueueElements are dequeued operations only.

R

RateLimitingPredicate - class org.apache.excalibur.event.impl.RateLimitingPredicate.
This enqueue predicate implements input rate policing.
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.
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.
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.
register(EventPipeline) - Method in class org.apache.excalibur.event.command.TPSPThreadManager
Register an EventPipeline with the ThreadManager.
register(EventPipeline) - Method in interface org.apache.excalibur.event.command.ThreadManager
Register an EventPipeline with the ThreadManager.
register(EventPipeline) - Method in class org.apache.excalibur.event.command.AbstractThreadManager
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.VariableSizePool
 
release(Object) - Method in interface org.apache.excalibur.mpool.Pool
Release the instance of the pooled object.
release(Object) - Method in class org.apache.excalibur.mpool.FixedSizePool
 
release(Object) - Method in class org.apache.excalibur.mpool.BlockingFixedSizePool
 
RepeatedCommand - interface org.apache.excalibur.event.command.RepeatedCommand.
A Signal is a specific type of QueueElement that denotes a Control code for the Queue system.
reset() - Method in interface org.apache.excalibur.mpool.Resettable
This method should be implemented to remove all costly resources in object.
Resettable - interface org.apache.excalibur.mpool.Resettable.
This interface standardizes the behaviour of a resettable object.
ROLE - Static variable in interface org.apache.excalibur.event.Sink
 
ROLE - Static variable in interface org.apache.excalibur.event.Queue
 
ROLE - Static variable in interface org.apache.excalibur.mpool.PoolManager
 
ROLE - Static variable in interface org.apache.excalibur.mpool.ObjectFactory
 
run() - Method in class org.apache.excalibur.event.command.TPSPThreadManager
 
run() - Method in class org.apache.excalibur.event.command.TPSPThreadManager.PipelineRunner
 
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.AbstractThreadManager.PipelineRunner
The code that actually pulls the events from the Sources and sends them to the event handler

S

setDepth(int) - Method in class org.apache.excalibur.event.impl.RateLimitingPredicate
Allows to set the bucket depth.
setDequeueInterceptor(DequeueInterceptor) - Method in interface org.apache.excalibur.event.Queue
Set the dequeue executable for this sink.
setDequeueInterceptor(DequeueInterceptor) - Method in class org.apache.excalibur.event.impl.AbstractQueue
Set the dequeue executable for this sink.
setEnqueuePredicate(EnqueuePredicate) - Method in interface org.apache.excalibur.event.Queue
Set the enqueue predicate 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 ThreadPool 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 interface org.apache.excalibur.event.Source
Sets the timeout on a blocking Source.
setTimeout(long) - Method in class org.apache.excalibur.event.impl.AbstractQueue
Set the timeout for the Queue in milliseconds.
shrink(int, long) - Method in class org.apache.excalibur.mpool.VariableSizePool
 
shrink(int, long) - Method in interface org.apache.excalibur.mpool.ManagablePool
Shrink the pool by the specified amount.
Signal - interface org.apache.excalibur.event.Signal.
A Signal is a specific type of queue element that denotes a Control code for the Queue system.
Sink - interface org.apache.excalibur.event.Sink.
A Sink implements the end of a finite-length event queue where elements are enqueued.
SinkClosedException - exception org.apache.excalibur.event.SinkClosedException.
A SinkClosedException is thrown when an enqueue operation occurs on a queue that is already closed.
SinkClosedException(String) - Constructor for class org.apache.excalibur.event.SinkClosedException
Create a SinkClosedException with an associated message.
SinkClosedException(String, Throwable) - Constructor for class org.apache.excalibur.event.SinkClosedException
Create a SinkClosedException with an associated message and the original exception that caused the problem.
SinkException - exception org.apache.excalibur.event.SinkException.
A SourceException is thrown when an enqueue operation fails.
SinkException(String) - Constructor for class org.apache.excalibur.event.SinkException
Construct a new SinkException instance.
SinkException(String, Throwable) - Constructor for class org.apache.excalibur.event.SinkException
Construct a new SinkException instance.
SinkFullException - exception org.apache.excalibur.event.SinkFullException.
A SinkException is thrown when an enqueue operation occurs on a queue that is already full.
SinkFullException(String) - Constructor for class org.apache.excalibur.event.SinkFullException
Create a SinkFullException with an associated message.
SinkFullException(String, Throwable) - Constructor for class org.apache.excalibur.event.SinkFullException
Create a SinkClosedException with an associated message and the original exception that caused the problem.
size() - Method in interface org.apache.excalibur.event.Source
Returns the number of elements waiting in this Source.
size() - Method in interface org.apache.excalibur.event.Sink
Returns the number of elements waiting in this Sink.
size() - Method in class org.apache.excalibur.event.impl.MultiCastSink
 
size() - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
 
size() - Method in class org.apache.excalibur.event.impl.FixedSizeQueue
Deprecated.  
size() - Method in class org.apache.excalibur.event.impl.DefaultQueue
Return the number of elements currently in the Queue.
size(long) - Method in class org.apache.excalibur.mpool.VariableSizePool
 
size(long) - Method in interface org.apache.excalibur.mpool.ManagablePool
Determine the pool's current size.
Source - interface org.apache.excalibur.event.Source.
A Source implements the side of an event queue where QueueElements are dequeued operations only.
SystemUtil - class org.apache.excalibur.util.SystemUtil.
A set of utility operations that provide necessary information about the architecture of the machine that the system is running on.

T

ThreadManager - interface org.apache.excalibur.event.command.ThreadManager.
A ThreadManager handles the thread policies for EventPipelines.
ThresholdEnqueuePredicate - class org.apache.excalibur.event.impl.ThresholdEnqueuePredicate.
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 org.apache.excalibur.event.command.TPCThreadManager.
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 org.apache.excalibur.event.command.TPSPThreadManager.
This is a ThreadManager which provides a threadpool per Sink per EventPipeline.
TPSPThreadManager.PipelineRunner - class org.apache.excalibur.event.command.TPSPThreadManager.PipelineRunner.
The PipelineRunner will run the pipelines
TPSPThreadManager.PipelineRunner(EventPipeline) - Constructor for class org.apache.excalibur.event.command.TPSPThreadManager.PipelineRunner
Create a PipelineRunner
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, long) - Constructor for class org.apache.excalibur.event.command.TPSPThreadManager
Constructor provides a specified number of threads per processor.
tryEnqueue(Object) - Method in interface org.apache.excalibur.event.Sink
Tries to enqueue an event, but instead of throwing exceptions, it returns a boolean value of whether the attempt was successful.
tryEnqueue(Object) - Method in class org.apache.excalibur.event.impl.MultiCastSink
 
tryEnqueue(Object) - Method in class org.apache.excalibur.event.impl.LossyMultiCastSink
 
tryEnqueue(Object) - Method in class org.apache.excalibur.event.impl.FixedSizeQueue
Deprecated.  
tryEnqueue(Object) - Method in class org.apache.excalibur.event.impl.DefaultQueue
 

V

VariableSizePool - class org.apache.excalibur.mpool.VariableSizePool.
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 org.apache.excalibur.util.system.Windows2000.
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 org.apache.excalibur.util.system.Windows95.
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 org.apache.excalibur.util.system.Windows98.
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 org.apache.excalibur.util.system.WindowsNT.
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 org.apache.excalibur.util.system.WindowsXP.
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.

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

Copyright © 2002 Apache Avalon Project. All Rights Reserved.