org.objectweb.dream.aggregator
Class BasicPushPullAggregatorImpl
java.lang.Object
org.objectweb.dream.AbstractComponent
org.objectweb.dream.aggregator.BasicPushPullAggregatorImpl
- All Implemented Interfaces:
- BindingController, LifeCycleController, Loggable, Pull, Push
- public class BasicPushPullAggregatorImpl
- extends AbstractComponent
- implements Push, Pull
Basic implementation of a Push/Pull aggregator. Each pushed message is stored
in an aggregated message. This aggregated message is returned by the pull
method, which then creates next aggregated message to be returned.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
messageManagerItf
protected MessageManager messageManagerItf
- the message manager client interface of this component.
nextAggregatedMessage
protected ExtensibleMessage nextAggregatedMessage
- The aggregated message that will be returned by the next call of the pull
method.
BasicPushPullAggregatorImpl
public BasicPushPullAggregatorImpl()
push
public void push(Message message,
Map context)
throws PushException
- Specified by:
push
in interface Push
- Throws:
PushException
- See Also:
Push.push(Message, Map)
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.