org.objectweb.dream.protocol.atomicity
Class AtomicRouterImpl
java.lang.Object
org.objectweb.dream.AbstractComponent
org.objectweb.dream.protocol.atomicity.AtomicRouterImpl
- All Implemented Interfaces:
- BindingController, LifeCycleController, Loggable, Push, SetReactorThread
- public class AtomicRouterImpl
- extends AbstractComponent
- implements Push, SetReactorThread
A Router that choose a route depending on the pushing thread. This component
provides an interface to set the thread that is considered as the reacting
thread.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
OUT_REACT_PUSH_ITF_NAME
public static final String OUT_REACT_PUSH_ITF_NAME
- the name of the client interface uesd to push messages if the pushing
thread is the reacting thred
- See Also:
- Constant Field Values
OUT_NOT_REACT_PUSH_ITF_NAME
public static final String OUT_NOT_REACT_PUSH_ITF_NAME
- The name of the client interface used to push messages if the pushing
thread is not the reacting thread
- See Also:
- Constant Field Values
AtomicRouterImpl
public AtomicRouterImpl()
push
public void push(Message message,
Map context)
throws PushException
- Specified by:
push
in interface Push
- Throws:
PushException
- See Also:
Push.push(Message, Map)
setReactorThread
public void setReactorThread(Thread reactorThread)
- Description copied from interface:
SetReactorThread
- Gives the thread that is executing a reaction.
- Specified by:
setReactorThread
in interface SetReactorThread
- Parameters:
reactorThread
- the thread that is executing a reaction.- See Also:
SetReactorThread.setReactorThread(Thread)
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.