org.objectweb.dream.aggregator
Class PullPullAggregatorFixedNumberImpl

java.lang.Object
  extended byorg.objectweb.dream.AbstractComponent
      extended byorg.objectweb.dream.aggregator.PullPullAggregatorFixedNumberImpl
All Implemented Interfaces:
AttributeController, BindingController, LifeCycleController, Loggable, Pull, PullPullAggregatorFixedNumberAttributeController

public class PullPullAggregatorFixedNumberImpl
extends AbstractComponent
implements Pull, PullPullAggregatorFixedNumberAttributeController

This aggregator aggregates a fixed number of messages. These messages are collected on its Pull input. The number of messages to be aggregated is set using the PullPullAggregatorFixedNumberAttributeController interface.


Field Summary
protected  MessageManager messageManagerItf
          the message manager client interface of this component
 
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
PullPullAggregatorFixedNumberImpl()
           
 
Method Summary
 void bindFc(String clientItfName, Object serverItf)
           
 int getNbMessagesToAggregate()
          Returns the number of messages that must be aggregated.
 String[] listFc()
           
 Message pull(Map context)
           
 void setNbMessagesToAggregate(int nb)
          Sets the number of messages that must be aggregated.
 
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
 

Field Detail

messageManagerItf

protected MessageManager messageManagerItf
the message manager client interface of this component

Constructor Detail

PullPullAggregatorFixedNumberImpl

public PullPullAggregatorFixedNumberImpl()
Method Detail

pull

public Message pull(Map context)
             throws PullException
Specified by:
pull in interface Pull
Throws:
PullException
See Also:
Pull.pull(Map)

getNbMessagesToAggregate

public int getNbMessagesToAggregate()
Description copied from interface: PullPullAggregatorFixedNumberAttributeController
Returns the number of messages that must be aggregated.

Specified by:
getNbMessagesToAggregate in interface PullPullAggregatorFixedNumberAttributeController
Returns:
the number of messages that must be aggregated.
See Also:
PullPullAggregatorFixedNumberAttributeController.getNbMessagesToAggregate()

setNbMessagesToAggregate

public void setNbMessagesToAggregate(int nb)
Description copied from interface: PullPullAggregatorFixedNumberAttributeController
Sets the number of messages that must be aggregated.

Specified by:
setNbMessagesToAggregate in interface PullPullAggregatorFixedNumberAttributeController
Parameters:
nb - the number to be set.
See Also:
PullPullAggregatorFixedNumberAttributeController.setNbMessagesToAggregate(int)

bindFc

public void bindFc(String clientItfName,
                   Object serverItf)
            throws NoSuchInterfaceException,
                   IllegalBindingException,
                   IllegalLifeCycleException
Specified by:
bindFc in interface BindingController
Throws:
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
See Also:
BindingController.bindFc(String, Object)

listFc

public String[] listFc()
Specified by:
listFc in interface BindingController
See Also:
BindingController.listFc()


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