org.objectweb.dream.queue
Class OutgoingHandlerAggregatingImpl

java.lang.Object
  extended by org.objectweb.dream.AbstractComponent
      extended by 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


Field Summary
protected  BufferRemove bufferRemove
          The buffer from which pulled messages are removed.
protected static String[] CLIENT_INTERFACE_NAMES
          The names of client interfaces.
 
Fields inherited from class org.objectweb.dream.AbstractComponent
bindingLogger, fcNeedAsyncStart, fcState, lifeCycleLogger, logger, weaveableC
 
Fields inherited from interface org.objectweb.dream.Pull
IN_PULL_ITF_NAME, OUT_PULL_ITF_NAME
 
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController
STARTED, STOPPED
 
Constructor Summary
OutgoingHandlerAggregatingImpl()
           
 
Method Summary
 void bindFc(String clientItfName, Object serverItf)
           
 String[] listFc()
           
 Message pull()
           
 
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
 

Field Detail

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.

Constructor Detail

OutgoingHandlerAggregatingImpl

public OutgoingHandlerAggregatingImpl()
Method Detail

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.