org.objectweb.dream.queue
Class OutgoingHandlerNonBlockingImpl

java.lang.Object
  extended by org.objectweb.dream.AbstractComponent
      extended by org.objectweb.dream.queue.OutgoingHandlerNonBlockingImpl
All Implemented Interfaces:
ContextualBindingController, NeedAsyncStartController, PrepareStopLifeCycleController, Loggable, Pull, BindingController, LifeCycleController

public class OutgoingHandlerNonBlockingImpl
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 messages from the buffer: if no message is removed from the buffer, a null message is pulled.


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
OutgoingHandlerNonBlockingImpl()
           
 
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

OutgoingHandlerNonBlockingImpl

public OutgoingHandlerNonBlockingImpl()
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.