org.objectweb.dream.protocol.utobcast
Class UTOImpl

java.lang.Object
  extended byorg.objectweb.dream.AbstractComponent
      extended byorg.objectweb.dream.protocol.utobcast.UTOImpl
All Implemented Interfaces:
BindingController, LifeCycleController, Loggable, Push

public class UTOImpl
extends AbstractComponent
implements Push

Implementation of the UTO component. This component handles UTO messages. Upon message reception,

In both cases, an ACK is sent to pleader and pbackup.


Field Summary
static String DELIVERY_ITF_NAME
          The commonly used name to refer to the deliveryItf interface.
protected  Push deliveryItf
          The interface to deliver messages.
protected  MessageManager messageManagerItf
          The interface to manage message lifecycle.
protected  Push outPushItf
          The interface to send ACK messages.
protected  ProcessMembership processMembershipItf
          The interface to retrieve process membership information.
static String TO_BE_DELIVERED_IN_ITF_NAME
          The commonly used name to refer to the toBeDeliveredInItf interface.
static String TO_BE_DELIVERED_OUT_ITF_NAME
          The commonly used name to refer to the toBeDeliveredOutItf interface.
protected  Push toBeDeliveredInItf
          The interface to store messages in the ToBeDelivered queue.
protected  Pull toBeDeliveredOutItf
          The interface to retrieve messages to be delivered from the toBeDelivered queue.
 
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
UTOImpl()
          Constructor.
 
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

DELIVERY_ITF_NAME

public static final String DELIVERY_ITF_NAME
The commonly used name to refer to the deliveryItf interface.

See Also:
Constant Field Values

TO_BE_DELIVERED_IN_ITF_NAME

public static final String TO_BE_DELIVERED_IN_ITF_NAME
The commonly used name to refer to the toBeDeliveredInItf interface.

See Also:
Constant Field Values

TO_BE_DELIVERED_OUT_ITF_NAME

public static final String TO_BE_DELIVERED_OUT_ITF_NAME
The commonly used name to refer to the toBeDeliveredOutItf interface.

See Also:
Constant Field Values

deliveryItf

protected Push deliveryItf
The interface to deliver messages.


toBeDeliveredInItf

protected Push toBeDeliveredInItf
The interface to store messages in the ToBeDelivered queue.


toBeDeliveredOutItf

protected Pull toBeDeliveredOutItf
The interface to retrieve messages to be delivered from the toBeDelivered queue.


outPushItf

protected Push outPushItf
The interface to send ACK messages.


processMembershipItf

protected ProcessMembership processMembershipItf
The interface to retrieve process membership information.


messageManagerItf

protected MessageManager messageManagerItf
The interface to manage message lifecycle.

Constructor Detail

UTOImpl

public UTOImpl()
Constructor.

Method Detail

push

public void push(Message message,
                 Map context)
          throws PushException
Specified by:
push in interface Push
Throws:
PushException
See Also:
Push.push(org.objectweb.dream.message.Message, java.util.Map)

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(java.lang.String, java.lang.Object)

listFc

public String[] listFc()
Specified by:
listFc in interface BindingController
See Also:
BindingController.listFc()


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