Package org.objectweb.dream.queue

Interface Summary
BufferAdd This interface defines methods that must be implemented by a buffer to allow components to add messages into it.
BufferAttributeController Base attribute controller interface for buffer implementations.
BufferAttributeControllerAscendingSequenceNumber Attribute controller for buffers that sort messages using an ascending sequence number.
BufferAttributeControllerSorted Sorted queue attribute controller.
BufferRemove This interface defines methods that must be implemented by a buffer to allow components to get or delete messages from it.
MessageComparableKeyManager Calculates keys for messages.
MessageKeyManager Calculates keys for messages.
MessageMatcher Determines which messages in a buffer can be returned by calls to BufferRemove.get() and BufferRemove.remove().
MissingSequenceNumber Interface that can be used by a queue sorting messages according to a sequence number (i.e. a long) to indicate that sequence numbers are missing.
MissingSequenceNumberKeyBased Interface that can be used by a queue sorting messages according to a sequence number (i.e. a long) to indicate that sequence numbers are missing.
PushQueueAttributeController Attribute controller for queue implementation with a push input.
UnlockKey Interface provided by the BufferKeyMutexSortedImpl component to unlock the key of the calling thread.
 

Class Summary
AbstractBufferImpl Abstract implementation of a buffer.
BufferAscendingSequenceNumberImpl Implementation of the Buffer interface using a sorted list.
BufferAscendingSequenceNumberImpl.Element This class represents elements of a linked list.
BufferFIFOImpl A buffer in which stored messages are available to get or remove in the same order as they are added (First In First Out).
BufferKeyMutexSortedImpl This buffer sorts messages using a key provided by a MessageKeyManager.
BufferKeyMutexSortedImpl.ListElem Object list elements.
BufferKeyMutexSortedImpl.MessageList Object list
BufferLIFOImpl A buffer in which stored messages are available to get or remove in the reverse order as they are added (Last In First Out).
BufferMatchingImpl A buffer in which stored messages are available to get or remove only if they are accepted by the message matcher bound to this component.
BufferSortingImpl A buffer in which stored messages are available to get or remove in the order of the "key" that is calculated for each message by the MessageComparableKeyManager component bound to this component when adding each message.
IncomingHandlerBlockingImpl An incoming handler that adds pushed messages into a buffer bound to it.
IncomingHandlerDroppingImpl An incoming handler that adds pushed messages into a buffer bound to it.
IncomingHandlerExceptionThrowingImpl An incoming handler that adds pushed messages into a buffer bound to it.
IncomingHandlerRemovingImpl An incoming handler that adds pushed messages into a buffer bound to it.
OutgoingHandlerAggregatingImpl An outgoing handler that returns messages removed from a buffer bound to it.
OutgoingHandlerBlockingImpl An outgoing handler that returns messages removed from a buffer bound to it.
OutgoingHandlerNonBlockingImpl An outgoing handler that returns messages removed from a buffer bound to it.
PushPullQueueFastImpl High performance implementation of a Push/Pull queue.
PushPullQueueNotSynchronizedImpl High performance implementation of a Push/Pull queue.
PushPushUnlockKeyImpl This component forwards incoming messages and then call UnlockKey.unlockKey().
SequenceNumberChunk Chunk interface for messages that have to be sequentially ordered.
 

Exception Summary
BufferOverflowException Exception thrown by queues when the maximum capacity of the queue is raised and the policy is to throw an exception.
 



Copyright © 2003, 2005 - INRIA Rhone-Alpes - All Rights Reserved.