|
||||||||||
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.DATImpl
Implementation of the DAT component. This component handles DAT messages.
Upon message reception, it stores the message into the
PendingMessages
queue, and then it sends a REP message to
pbackup. Finally, it increments the sequence number. Note that this component
may trigger a backup election if it detects its failure.
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 REP messages to pbackup. |
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. |
protected SequenceNumber |
sequenceNumberItf
The interface to get/set the sequence number. |
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 | |
DATImpl()
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 SequenceNumber sequenceNumberItf
protected BackupElection backupElectionItf
protected MessageManager messageManagerItf
Constructor Detail |
public DATImpl()
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 |