Uses of Interface
org.apache.excalibur.event.Sink

Packages that use Sink

org.apache.excalibur.event
org.apache.excalibur.event.command
org.apache.excalibur.event.impl
org.apache.excalibur.mpool

Uses of Sink in org.apache.excalibur.event

Subinterfaces of Sink in org.apache.excalibur.event

interface

Queue A Source implements the side of an event queue where QueueElements are dequeued operations only.

Methods in org.apache.excalibur.event with parameters of type Sink

boolean	EnqueuePredicate.accept(java.lang.Object element, Sink modifyingSink) Tests the given element for acceptance onto the m_sink.
boolean	EnqueuePredicate.accept(java.lang.Object[] elements, Sink modifyingSink) Tests the given element for acceptance onto the m_sink.

Uses of Sink in org.apache.excalibur.event.command

Methods in org.apache.excalibur.event.command that return Sink

Sink	CommandManager.getCommandSink() Get the Command Sink so that you can enqueue new commands.

Methods in org.apache.excalibur.event.command with parameters of type Sink

boolean	CommandManager.accept(java.lang.Object element, Sink modifyingSink) Tests the given element for acceptance onto the m_sink.
boolean	CommandManager.accept(java.lang.Object[] elements, Sink modifyingSink) Tests the given element for acceptance onto the m_sink.

Uses of Sink in org.apache.excalibur.event.impl

Classes in org.apache.excalibur.event.impl that implement Sink

class	AbstractQueue Provides the base functionality for the other Queue types.
class	DefaultQueue The default queue implementation is a variable size queue.
class	FixedSizeQueue Deprecated. Use the DefaultQueue as it properly supports the EnqueuePredicates
class	LossyMultiCastSink This is a org.apache.excalibur.event.seda.event.Sink implementation that multicasts enqueue operations to the contained and concrete sink objects.
class	MultiCastSink This is a org.apache.excalibur.event.seda.event.Sink implementation that multicasts enqueue operations to the contained and concrete sink objects.

Methods in org.apache.excalibur.event.impl with parameters of type Sink

boolean	ThresholdEnqueuePredicate.accept(java.lang.Object element, Sink modifyingSink) Returns true if the Sink size + 1 (the element) is less than the threshold.
boolean	ThresholdEnqueuePredicate.accept(java.lang.Object[] elements, Sink modifyingSink) Returns true if the Sink size + the number of elements is less than the threshold.
boolean	RateLimitingPredicate.accept(java.lang.Object element, Sink sink)
boolean	RateLimitingPredicate.accept(java.lang.Object[] elements, Sink sink)
boolean	NullEnqueuePredicate.accept(java.lang.Object element, Sink modifyingSink)
boolean	NullEnqueuePredicate.accept(java.lang.Object[] element, Sink modifyingSink)

Uses of Sink in org.apache.excalibur.mpool

Constructors in org.apache.excalibur.mpool with parameters of type Sink

DefaultPoolManager(Sink commandSink)