com.fr.third.jgroups.protocols.tom

类 SenderManager

java.lang.Object

com.fr.third.jgroups.protocols.tom.SenderManager

public class SenderManager
extends java.lang.Object

Keeps track of all sent messages, until the final sequence number is known

从以下版本开始:

3.1

作者:

Pedro Ruivo

字段概要

字段

限定符和类型	字段和说明
static long	NOT_READY

构造器概要

构造器

构造器和说明
SenderManager()

方法概要

方法

限定符和类型	方法和说明
void	addNewMessageToSend(MessageID messageID, java.util.Collection<Address> destinations, long initialSequenceNumber, boolean deliverToMyself) Add a new message sent
long	addPropose(MessageID messageID, Address from, long sequenceNumber) Add a propose from a member in destination set
void	clear() removes all pending messages
java.util.Set<Address>	getDestination(MessageID messageID) obtains the destination set of a message
java.util.Collection<MessageID>	getPendingMessageIDs()
boolean	markSent(MessageID messageID) Mark the message as sent
long	removeLeavers(MessageID messageID, java.util.Collection<Address> leavers)

从类继承的方法 java.lang.Object

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

字段详细资料

NOT_READY

public static final long NOT_READY

另请参阅:

常量字段值

构造器详细资料

SenderManager

public SenderManager()

方法详细资料

addNewMessageToSend

public void addNewMessageToSend(MessageID messageID,
                       java.util.Collection<Address> destinations,
                       long initialSequenceNumber,
                       boolean deliverToMyself)

Add a new message sent

参数:

messageID - the message ID

destinations - the destination set

initialSequenceNumber - the initial sequence number

deliverToMyself - true if *this* member is in destination sent, false otherwise

addPropose

public long addPropose(MessageID messageID,
              Address from,
              long sequenceNumber)

Add a propose from a member in destination set

参数:

messageID - the message ID

from - the originator of the propose

sequenceNumber - the proposed sequence number

返回:

NOT_READY if the final sequence number is not know, or the final sequence number

markSent

public boolean markSent(MessageID messageID)

Mark the message as sent

参数:

messageID - the message ID

返回:

return true if *this* member is in destination set

getDestination

public java.util.Set<Address> getDestination(MessageID messageID)

obtains the destination set of a message

参数:

messageID - the message ID

返回:

the destination set

clear

public void clear()

removes all pending messages

getPendingMessageIDs

public java.util.Collection<MessageID> getPendingMessageIDs()

removeLeavers

public long removeLeavers(MessageID messageID,
                 java.util.Collection<Address> leavers)