org.objectweb.dream.protocol.atomicity
Class AtomicRouterImpl

java.lang.Object
  extended by org.objectweb.dream.AbstractComponent
      extended by org.objectweb.dream.protocol.atomicity.AtomicRouterImpl
All Implemented Interfaces:
ContextualBindingController, NeedAsyncStartController, PrepareStopLifeCycleController, Loggable, SetReactorThread, Push, BindingController, LifeCycleController

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.


Field Summary
static 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
static String OUT_REACT_PUSH_ITF_NAME
          the name of the client interface uesd to push messages if the pushing thread is the reacting thred
 
Fields inherited from class org.objectweb.dream.AbstractComponent
bindingLogger, fcNeedAsyncStart, fcState, lifeCycleLogger, logger, weaveableC
 
Fields inherited from interface org.objectweb.dream.Push
IN_PUSH_ITF_NAME, INCOMING_IN_PUSH_ITF_NAME, INCOMING_OUT_PUSH_ITF_NAME, OUT_PUSH_ITF_NAME, OUTGOING_IN_PUSH_ITF_NAME, OUTGOING_OUT_PUSH_ITF_NAME
 
Fields inherited from interface org.objectweb.dream.protocol.atomicity.SetReactorThread
SET_REACTOR_THREAD_ITF_NAME
 
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController
STARTED, STOPPED
 
Constructor Summary
AtomicRouterImpl()
           
 
Method Summary
 void bindFc(String clientItfName, Object serverItf)
           
 String[] listFc()
           
 void push(Message message)
           
 void setReactorThread(Thread reactorThread)
          Gives the thread that is executing a reaction.
 
Methods inherited from class org.objectweb.dream.AbstractComponent
beforeFirstStart, bindFc, getFcNeedAsyncStart, getFcState, initComponent, lookupFc, prepareStopFc, setLogger, startFc, stopFc, unbindFc
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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
Constructor Detail

AtomicRouterImpl

public AtomicRouterImpl()
Method Detail

push

public void push(Message message)
          throws PushException
Specified by:
push in interface Push
Throws:
PushException
See Also:
Push.push(Message)

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


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