rice.rm.messaging
Class RMTimeoutMsg

java.lang.Object
  rice.pastry.messaging.Message
      rice.rm.messaging.RMMessage
          rice.rm.messaging.RMTimeoutMsg

All Implemented Interfaces:

java.io.Serializable

public class RMTimeoutMsg

extends RMMessage

implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested classes inherited from class rice.rm.messaging.RMMessage

RMMessage.KEEntry

Field Summary

Fields inherited from class rice.rm.messaging.RMMessage

_seqno, _source

Constructor Summary

RMTimeoutMsg(NodeHandle source, Address address, Credentials authorCred, int seqno, RMRequestKeysMsg.WrappedMsg _wmsg)
Constructor

Method Summary

void	handleDeliverMessage(RMImpl rm) If the RMResponseKeysMsg corresponding to the wrapped RMRequestKeysMsg was received (done by having same 'eventId' field in RMRequestKeysMsg & corresponding RMResponseKeysMsg) then nothing needs to be done.
java.lang.String	toString()

Methods inherited from class rice.rm.messaging.RMMessage

getCredentials, getSeqno, getSource

Methods inherited from class rice.pastry.messaging.Message

getDate, getDestination, getSenderId, getStream, hasPriority, setPriority, setSenderId, stamp

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

RMTimeoutMsg

public RMTimeoutMsg(NodeHandle source,
                    Address address,
                    Credentials authorCred,
                    int seqno,
                    RMRequestKeysMsg.WrappedMsg _wmsg)

Constructor

Parameters:

source - the local node itself

address - the RM application address

authorCred - the credentials of the source

seqno - for debugging purposes only

_wmsg - the wrapped RMRequestKeysMsg

Method Detail

handleDeliverMessage

public void handleDeliverMessage(RMImpl rm)

If the RMResponseKeysMsg corresponding to the wrapped RMRequestKeysMsg was received (done by having same 'eventId' field in RMRequestKeysMsg & corresponding RMResponseKeysMsg) then nothing needs to be done. Otherwise, the wrapped RMRequestKeysMsg is resent, while incrementing its attempt number. Note that after MAXATTEMPTS number of timeouts, the message will be ignored even if not successfully delivered.

Specified by:

handleDeliverMessage in class RMMessage

toString

public java.lang.String toString()