|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.dream.AbstractComponent
org.objectweb.dream.queue.AbstractBufferImpl
org.objectweb.dream.queue.BufferImpl
Basic implementation of the Buffer
interface using a
LinkedList
. This buffer does not sort messages. They are
added and removed in a FIFO order.
Indicators on available space, available messages, and stored messages are expressed as number of messages.
Buffer
,
AbstractBufferImpl
Field Summary |
Fields inherited from class org.objectweb.dream.queue.AbstractBufferImpl |
availableMessagesIndicator, lock, maxCapacity, messageManagerItf, storedMessagesIndicator |
Fields inherited from class org.objectweb.dream.AbstractComponent |
bindingLogger, componentDesc, fcState, firstStart, lifeCycleLogger, logger, weaveableC |
Fields inherited from interface org.objectweb.dream.queue.Buffer |
ITF_NAME |
Fields inherited from interface org.objectweb.dream.queue.BufferAddFirstLast |
ITF_NAME |
Fields inherited from interface org.objectweb.dream.queue.BufferRemoveFirstLast |
ITF_NAME |
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController |
STARTED, STOPPED |
Constructor Summary | |
BufferImpl()
|
Method Summary | |
void |
bindFc(String clientItfName,
Object serverItf)
|
protected boolean |
canAdd(Message message)
Checks whether the given message can be added into the buffer. |
protected void |
doAdd(Message message)
Adds a message to the buffer. |
protected void |
doAddFirst(Message message)
Adds a message to the beginning of the buffer. |
protected void |
doAddLast(Message message)
Adds a message to end of the buffer. |
protected Message |
doGet()
Gets a message from the buffer. |
protected Message |
doGetFirst()
Gets the first message from the buffer. |
protected Message |
doGetLast()
Gets the last message from the buffer. |
protected Message |
doRemove()
Removes a message from the buffer. |
protected Message |
doRemoveFirst()
Removes the first message from the buffer. |
protected Message |
doRemoveLast()
Removes the last message from the buffer. |
protected boolean |
hasAvailableMessage()
Checks whether there is an available message. |
String[] |
listFc()
|
Methods inherited from class org.objectweb.dream.queue.AbstractBufferImpl |
add, addFirst, addLast, availableMessagesIndicator, availableSpaceIndicator, get, getCurrentSize, getFirst, getLast, getMaxCapacity, incrementAvailableMessagesIndicator, incrementStoredMessagesIndicator, remove, removeFirst, removeLast, setMaxCapacity, storedMessagesIndicator |
Methods inherited from class org.objectweb.dream.AbstractComponent |
beforeFirstStart, getFcState, initComponent, lookupFc, setLogger, startFc, stopFc, unbindFc |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public BufferImpl()
Method Detail |
protected boolean hasAvailableMessage()
AbstractBufferImpl
hasAvailableMessage
in class AbstractBufferImpl
true
if there is an available message.AbstractBufferImpl.hasAvailableMessage()
protected boolean canAdd(Message message)
AbstractBufferImpl
canAdd
in class AbstractBufferImpl
message
- the message to be tested.
true
if the message can be added.AbstractBufferImpl.canAdd(org.objectweb.dream.message.Message)
protected void doAdd(Message message)
AbstractBufferImpl
AbstractBufferImpl.add(org.objectweb.dream.message.Message)
method.
doAdd
in class AbstractBufferImpl
message
- the message to be added.AbstractBufferImpl.doAdd(org.objectweb.dream.message.Message)
protected Message doRemove()
AbstractBufferImpl
AbstractBufferImpl.remove()
method.
doRemove
in class AbstractBufferImpl
AbstractBufferImpl.doRemove()
protected Message doGet()
AbstractBufferImpl
AbstractBufferImpl.remove()
method.
doGet
in class AbstractBufferImpl
AbstractBufferImpl.doGet()
protected void doAddFirst(Message message)
AbstractBufferImpl
AbstractBufferImpl.add(org.objectweb.dream.message.Message)
method.
doAddFirst
in class AbstractBufferImpl
message
- the message to be added.AbstractBufferImpl.doAddFirst(org.objectweb.dream.message.Message)
protected void doAddLast(Message message)
AbstractBufferImpl
AbstractBufferImpl.add(org.objectweb.dream.message.Message)
method.
doAddLast
in class AbstractBufferImpl
message
- the message to be added.AbstractBufferImpl.doAddLast(org.objectweb.dream.message.Message)
protected Message doGetFirst()
AbstractBufferImpl
AbstractBufferImpl.remove()
method.
doGetFirst
in class AbstractBufferImpl
AbstractBufferImpl.doGetFirst()
protected Message doGetLast()
AbstractBufferImpl
AbstractBufferImpl.remove()
method.
doGetLast
in class AbstractBufferImpl
AbstractBufferImpl.doGetLast()
protected Message doRemoveFirst()
AbstractBufferImpl
AbstractBufferImpl.remove()
method.
doRemoveFirst
in class AbstractBufferImpl
AbstractBufferImpl.doRemoveFirst()
protected Message doRemoveLast()
AbstractBufferImpl
AbstractBufferImpl.remove()
method.
doRemoveLast
in class AbstractBufferImpl
AbstractBufferImpl.doRemoveLast()
public void bindFc(String clientItfName, Object serverItf) throws NoSuchInterfaceException, IllegalBindingException, IllegalLifeCycleException
bindFc
in interface BindingController
bindFc
in class AbstractBufferImpl
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
BindingController.bindFc(String,
Object)
public String[] listFc()
listFc
in interface BindingController
listFc
in class AbstractBufferImpl
BindingController.listFc()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |