org.objectweb.dream.queue
Class BasicPushPushPassiveQueueImpl

java.lang.Object
  extended byorg.objectweb.dream.AbstractComponent
      extended byorg.objectweb.dream.queue.AbstractPushQueueImpl
          extended byorg.objectweb.dream.queue.BasicPushPushPassiveQueueImpl
All Implemented Interfaces:
AttributeController, BindingController, LifeCycleController, Loggable, Push, PushPushPassiveQueueAttributeController, PushQueueAttributeController, QueueAttributeController

public class BasicPushPushPassiveQueueImpl
extends AbstractPushQueueImpl
implements PushPushPassiveQueueAttributeController

Push/Push queue implemented using a passive component. It use the PushPushPassiveQueueAttributeController attribute controller to open or close its output.


Field Summary
protected  boolean open
           
protected  Push outPushItf
           
 
Fields inherited from class org.objectweb.dream.queue.AbstractPushQueueImpl
maxCapacity, messageManagerItf, overflowPolicy, waitingList
 
Fields inherited from class org.objectweb.dream.AbstractComponent
bindingLogger, componentDesc, fcState, lifeCycleLogger, logger, weaveableC
 
Fields inherited from interface org.objectweb.dream.Push
IN_PUSH_ITF_NAME, OUT_PUSH_ITF_NAME
 
Fields inherited from interface org.objectweb.dream.queue.PushQueueAttributeController
BLOCK_OVERFLOW_POLICY, DROP_OVERFLOW_POLICY, EXCEPTION_OVERFLOW_POLICY
 
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController
STARTED, STOPPED
 
Constructor Summary
BasicPushPushPassiveQueueImpl()
           
 
Method Summary
 void bindFc(String clientItfName, Object serverItf)
           
 boolean getOutputStatus()
          Returns the output status.
 String[] listFc()
           
 void push(Message message, Map context)
           
 void setOutputStatus(boolean outputStatus)
          Sets the output status.
 
Methods inherited from class org.objectweb.dream.queue.AbstractPushQueueImpl
getCurrentSize, getMaxCapacity, getOverflowPolicy, handleOverflow, setMaxCapacity, setOverflowPolicy
 
Methods inherited from class org.objectweb.dream.AbstractComponent
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
 

Field Detail

outPushItf

protected Push outPushItf

open

protected boolean open
Constructor Detail

BasicPushPushPassiveQueueImpl

public BasicPushPushPassiveQueueImpl()
Method Detail

push

public void push(Message message,
                 Map context)
          throws PushException
Specified by:
push in interface Push
Overrides:
push in class AbstractPushQueueImpl
Throws:
PushException
See Also:
Push.push(Message, Map)

getOutputStatus

public boolean getOutputStatus()
Description copied from interface: PushPushPassiveQueueAttributeController
Returns the output status. true means the output is open, false means the output is close, no message will be delivered on.

Specified by:
getOutputStatus in interface PushPushPassiveQueueAttributeController
Returns:
the output status.
See Also:
PushPushPassiveQueueAttributeController.getOutputStatus()

setOutputStatus

public void setOutputStatus(boolean outputStatus)
Description copied from interface: PushPushPassiveQueueAttributeController
Sets the output status.

Specified by:
setOutputStatus in interface PushPushPassiveQueueAttributeController
Parameters:
outputStatus - if true the output is opened, otherwise the output is closed.
See Also:
PushPushPassiveQueueAttributeController.setOutputStatus(boolean)

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 AbstractPushQueueImpl
Throws:
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
See Also:
BindingController.bindFc(String, Object)


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