org.objectweb.dream.queue
Class BufferFIFOImpl
java.lang.Object
org.objectweb.dream.AbstractComponent
org.objectweb.dream.queue.AbstractBufferImpl
org.objectweb.dream.queue.BufferFIFOImpl
- All Implemented Interfaces:
- ContextualBindingController, NeedAsyncStartController, PrepareStopLifeCycleController, Loggable, BufferAdd, BufferAttributeController, BufferRemove, AttributeController, BindingController, LifeCycleController
public class BufferFIFOImpl
- extends AbstractBufferImpl
A buffer in which stored messages are available to get
or
remove
in the same order as they are added
(First In First Out).
Method Summary |
protected void |
doAdd(Message message)
Adds a message to the buffer. |
protected Message |
doGet()
Gets a message from the buffer. |
protected Message |
doRemove()
Removes a message from the buffer. |
protected Message |
doRemoveAll()
Removes all the messages stored into the buffer. |
Methods inherited from class org.objectweb.dream.queue.AbstractBufferImpl |
add, availableSpace, bindFc, canAdd, get, getCurrentSize, getMaxCapacity, hasAvailableMessage, incrementAvailableMessagesCount, incrementStoredMessagesCount, listFc, remove, removeAll, setMaxCapacity, tryAdd, tryGet, tryRemove |
Methods inherited from class org.objectweb.dream.AbstractComponent |
beforeFirstStart, bindFc, getFcNeedAsyncStart, getFcState, initComponent, lookupFc, prepareStopFc, setLogger, startFc, stopFc, unbindFc |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
messages
protected LinkedList<Message> messages
- The messages stored in this buffer, in adding order (FIFO).
BufferFIFOImpl
public BufferFIFOImpl()
doAdd
protected void doAdd(Message message)
- Description copied from class:
AbstractBufferImpl
- Adds a message to the buffer. This method should not check if there is
enough available space provided it has already been done in the
AbstractBufferImpl.add(org.objectweb.dream.message.Message)
method. The lock
has been acquired when this
method is called.
- Specified by:
doAdd
in class AbstractBufferImpl
- Parameters:
message
- the message to be added.
doGet
protected Message doGet()
- Description copied from class:
AbstractBufferImpl
- Gets a message from the buffer. This method should not check if there is a
message available provided it has already been done in the
AbstractBufferImpl.get()
method. The lock
has been acquired when this method is
called.
- Specified by:
doGet
in class AbstractBufferImpl
- Returns:
- a message.
doRemove
protected Message doRemove()
- Description copied from class:
AbstractBufferImpl
- Removes a message from the buffer. This method should not check if there is
a message available provided it has already been done in the
AbstractBufferImpl.remove()
method. The lock
has been acquired when this
method is called.
- Specified by:
doRemove
in class AbstractBufferImpl
- Returns:
- a message.
doRemoveAll
protected Message doRemoveAll()
- Description copied from class:
AbstractBufferImpl
- Removes all the messages stored into the buffer. The
lock
has
been acquired when this method is called.
- Specified by:
doRemoveAll
in class AbstractBufferImpl
- Returns:
- an aggregated message.
Copyright © 2003, 2005 - INRIA Rhone-Alpes - All Rights Reserved.