org.objectweb.dream.protocol.utobcast
Class PendingMessagesDataStructureImpl

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

public class PendingMessagesDataStructureImpl
extends AbstractComponent
implements Push, ReceiveAck, Pull

Implementation of the PendingMessagesDataStructure component. This component stores pending messages. It is accessed by the REP and ACK components.


Field Summary
protected  MessageManager messageManagerItf
          The interface to manage message lifecycle.
static String PENDING_MESSAGES_OUT_ITF_NAME
          The commonly used name to refer to the pendingMessageOutItf interface.
protected  ProcessMembership processMembershipItf
          The interface to retrieve process membership information.
 
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.dream.protocol.utobcast.ReceiveAck
ITF_NAME
 
Fields inherited from interface org.objectweb.dream.Pull
IN_PULL_ITF_NAME, OUT_PULL_ITF_NAME
 
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController
STARTED, STOPPED
 
Constructor Summary
PendingMessagesDataStructureImpl()
          Constructor.
 
Method Summary
 void bindFc(String clientItfName, Object serverItf)
           
 String[] listFc()
           
 Message pull(Map context)
           
 void push(Message message, Map context)
           
 void receiveAck(Message message)
          Handles the received ACK message.
 
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

PENDING_MESSAGES_OUT_ITF_NAME

public static final String PENDING_MESSAGES_OUT_ITF_NAME
The commonly used name to refer to the pendingMessageOutItf interface.

See Also:
Constant Field Values

processMembershipItf

protected ProcessMembership processMembershipItf
The interface to retrieve process membership information.


messageManagerItf

protected MessageManager messageManagerItf
The interface to manage message lifecycle.

Constructor Detail

PendingMessagesDataStructureImpl

public PendingMessagesDataStructureImpl()
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)

pull

public Message pull(Map context)
             throws PullException
Specified by:
pull in interface Pull
Throws:
PullException
See Also:
Pull.pull(java.util.Map)

receiveAck

public void receiveAck(Message message)
Description copied from interface: ReceiveAck
Handles the received ACK message.

Specified by:
receiveAck in interface ReceiveAck
Parameters:
message - the ACK message.
See Also:
ReceiveAck.receiveAck(Message)

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.