org.objectweb.dream.queue
Class OutgoingHandlerAggregatingImpl
java.lang.Object
org.objectweb.dream.AbstractComponent
org.objectweb.dream.queue.OutgoingHandlerAggregatingImpl
- All Implemented Interfaces:
- ContextualBindingController, NeedAsyncStartController, PrepareStopLifeCycleController, Loggable, Pull, BindingController, LifeCycleController
public class OutgoingHandlerAggregatingImpl
- extends AbstractComponent
- implements Pull
An outgoing handler that returns
messages removed from a
buffer
bound to it. This component uses
non blocking calls for removing
ALL messages
from the buffer. The pulled messages are aggregated messages that contain as
sub messages all the messages that have been removed from the buffer. If no
message is removed from the buffer, the returned message is null
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 |
CLIENT_INTERFACE_NAMES
protected static final String[] CLIENT_INTERFACE_NAMES
- The names of client interfaces.
bufferRemove
protected BufferRemove bufferRemove
- The buffer from which pulled messages are removed.
OutgoingHandlerAggregatingImpl
public OutgoingHandlerAggregatingImpl()
pull
public Message pull()
throws PullException
- Specified by:
pull
in interface Pull
- Throws:
PullException
- See Also:
Pull.pull()
listFc
public String[] listFc()
- Specified by:
listFc
in interface BindingController
- See Also:
BindingController.listFc()
bindFc
public void bindFc(String clientItfName,
Object serverItf)
throws NoSuchInterfaceException,
IllegalBindingException,
IllegalLifeCycleException
- Specified by:
bindFc
in interface BindingController
- Overrides:
bindFc
in class AbstractComponent
- Throws:
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
- See Also:
BindingController.bindFc(String,
Object)
Copyright © 2003, 2005 - INRIA Rhone-Alpes - All Rights Reserved.