org.objectweb.dream.queue
Class PullOutgoingHandlerImpl

java.lang.Object
  extended byorg.objectweb.dream.AbstractComponent
      extended byorg.objectweb.dream.queue.AbstractPullOutgoingHandlerImpl
          extended byorg.objectweb.dream.queue.PullOutgoingHandlerImpl
All Implemented Interfaces:
AttributeController, BindingController, LifeCycleController, Loggable, Pull, PullQueueAttributeController

public class PullOutgoingHandlerImpl
extends AbstractPullOutgoingHandlerImpl

Basic implementation of a Pull outgoing handler.


Field Summary
 
Fields inherited from class org.objectweb.dream.queue.AbstractPullOutgoingHandlerImpl
blockingPull, bufferItf, bufferRemoveFirstLastItf
 
Fields inherited from class org.objectweb.dream.AbstractComponent
bindingLogger, componentDesc, fcState, firstStart, 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
PullOutgoingHandlerImpl()
           
 
Method Summary
protected  Message doPull()
          Pulls a message from the buffer (i.e. get or remove).
protected  boolean hasAvailableMessage()
          Checks whether there is an available message.
 
Methods inherited from class org.objectweb.dream.queue.AbstractPullOutgoingHandlerImpl
bindFc, getBlockingPull, listFc, pull, setBlockingPull
 
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

PullOutgoingHandlerImpl

public PullOutgoingHandlerImpl()
Method Detail

hasAvailableMessage

protected boolean hasAvailableMessage()
Description copied from class: AbstractPullOutgoingHandlerImpl
Checks whether there is an available message.

Specified by:
hasAvailableMessage in class AbstractPullOutgoingHandlerImpl
Returns:
true if there is an available message.
See Also:
AbstractPullOutgoingHandlerImpl.hasAvailableMessage()

doPull

protected Message doPull()
                  throws InterruptedException
Description copied from class: AbstractPullOutgoingHandlerImpl
Pulls a message from the buffer (i.e. get or remove). This method should not check if there is a message available provided it has already been done.

Specified by:
doPull in class AbstractPullOutgoingHandlerImpl
Returns:
a message.
Throws:
InterruptedException - if it is interrupted while waiting an available message.
See Also:
AbstractPullOutgoingHandlerImpl.doPull()


Copyright © 2003, 2004 - INRIA Rhone-Alpes - All Rights Reserved.