org.objectweb.dream.aggregator
Class PushPushDeAggregatorImpl

java.lang.Object
  extended byorg.objectweb.dream.AbstractComponent
      extended byorg.objectweb.dream.PushPushDreamComponent
          extended byorg.objectweb.dream.aggregator.PushPushDeAggregatorImpl
All Implemented Interfaces:
BindingController, LifeCycleController, Loggable, Push

public class PushPushDeAggregatorImpl
extends PushPushDreamComponent

Basic implementation of a Push/Push de-aggregator. Each sub message in the pushed message is sent on the output. The pushed message is then deleted.


Field Summary
protected  MessageManager messageManagerItf
          the message manager client interface of this component.
 
Fields inherited from class org.objectweb.dream.PushPushDreamComponent
outPushItf
 
Fields inherited from class org.objectweb.dream.AbstractComponent
bindingLogger, componentDesc, fcState, firstStart, 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.fractal.api.control.LifeCycleController
STARTED, STOPPED
 
Constructor Summary
PushPushDeAggregatorImpl()
           
 
Method Summary
 void bindFc(String clientItfName, Object serverItf)
           
 String[] listFc()
           
 void push(Message message, 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

messageManagerItf

protected MessageManager messageManagerItf
the message manager client interface of this component.

Constructor Detail

PushPushDeAggregatorImpl

public PushPushDeAggregatorImpl()
Method Detail

push

public void push(Message message,
                 Map context)
          throws PushException
Throws:
PushException
See Also:
Push.push(Message, Map)

listFc

public String[] listFc()
See Also:
BindingController.listFc()

bindFc

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


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