org.objectweb.dream.queue
Class BasicPushPushActiveQueueImpl

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

public class BasicPushPushActiveQueueImpl
extends AbstractPushQueueImpl

Active Push/Push queue. Messages are receive on input and an activity push them on the output.


Field Summary
protected  Push outPushItf
           
protected  Task queueTask
           
 
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
BasicPushPushActiveQueueImpl()
           
 
Method Summary
 void bindFc(String clientItfName, Object serverItf)
           
protected  void handlePushException(Message message, PushException exception)
          Handles a PushExceptionoccuring when the activity try to push a message.
protected  void initComponent(Component componentItf)
           
 String[] listFc()
           
 
Methods inherited from class org.objectweb.dream.queue.AbstractPushQueueImpl
getCurrentSize, getMaxCapacity, getOverflowPolicy, handleOverflow, push, setMaxCapacity, setOverflowPolicy
 
Methods inherited from class org.objectweb.dream.AbstractComponent
getFcState, 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

queueTask

protected Task queueTask
Constructor Detail

BasicPushPushActiveQueueImpl

public BasicPushPushActiveQueueImpl()
Method Detail

handlePushException

protected void handlePushException(Message message,
                                   PushException exception)
Handles a PushExceptionoccuring when the activity try to push a message. This implementation simlpy delete message using message manger.

Parameters:
message - the pushed message
exception - the exceptino thrown during the push call.

initComponent

protected void initComponent(Component componentItf)
                      throws InitializationException
Throws:
InitializationException

listFc

public String[] listFc()
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.