org.objectweb.dream.aggregator
Class PullPullAggregatorContextualImpl

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

public class PullPullAggregatorContextualImpl
extends AbstractComponent
implements Pull

This aggregator has a pull output on which it receives pull calls requiring an aggregated message. The number of aggregated messages is specified has a context parameter of the pull call. These messages are collected on its Pull input.

See Also:
PullPullAggregatorContextualKey

Field Summary
protected  Pull inPullItf
           
protected  MessageManager messageManagerItf
           
 
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
PullPullAggregatorContextualImpl()
           
 
Method Summary
 void bindFc(String clientItfName, Object serverItf)
           
 String[] listFc()
           
 Message pull(Map context)
           
 
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

inPullItf

protected Pull inPullItf

messageManagerItf

protected MessageManager messageManagerItf
Constructor Detail

PullPullAggregatorContextualImpl

public PullPullAggregatorContextualImpl()
Method Detail

pull

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

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


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