|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.dream.AbstractComponent
org.objectweb.dream.protocol.utobcast.REPImpl
Implementation of the REP component. This component handles REP messages.
Upon message reception, it stores the message into the
PendingMessages
queue. Then it sends UTO messages all the
processes but pleader, and an ACK message to pleader. Note that in case this
component detects a failure of pleader, it becomes leader, and trigger a
backup election.
Field Summary | |
protected BackupElection |
backupElectionItf
The interface to elect a new backup. |
protected MessageManager |
messageManagerItf
The interface to manage message lifecycle. |
protected Push |
outPushItf
The interface to send UTO and ACK messages. |
static String |
PENDING_MESSAGES_IN_ITF_NAME
The commonly used name to refer to the pendingMessageInItf
interface. |
protected Push |
pendingMessagesInItf
The interface to store messages in the PendingMessage queue. |
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.fractal.api.control.LifeCycleController |
STARTED, STOPPED |
Constructor Summary | |
REPImpl()
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 |
public static final String PENDING_MESSAGES_IN_ITF_NAME
pendingMessageInItf
interface.
protected Push pendingMessagesInItf
PendingMessage
queue.
protected Push outPushItf
protected ProcessMembership processMembershipItf
protected BackupElection backupElectionItf
protected MessageManager messageManagerItf
Constructor Detail |
public REPImpl()
Method Detail |
public void push(Message message, Map context) throws PushException
push
in interface Push
PushException
Push.push(org.objectweb.dream.message.Message,
java.util.Map)
public void bindFc(String clientItfName, Object serverItf) throws NoSuchInterfaceException, IllegalBindingException, IllegalLifeCycleException
bindFc
in interface BindingController
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
BindingController.bindFc(java.lang.String,
java.lang.Object)
public String[] listFc()
listFc
in interface BindingController
BindingController.listFc()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |