public class SenderManager extends Object
Modifier and Type | Field and Description |
---|---|
static long |
NOT_READY |
Constructor and Description |
---|
SenderManager() |
Modifier and Type | Method and Description |
---|---|
void |
addNewMessageToSend(MessageID messageID,
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
|
Set<Address> |
getDestination(MessageID messageID)
obtains the destination set of a message
|
Collection<MessageID> |
getPendingMessageIDs() |
boolean |
markSent(MessageID messageID)
Mark the message as sent
|
long |
removeLeavers(MessageID messageID,
Collection<Address> leavers) |
public static final long NOT_READY
public void addNewMessageToSend(MessageID messageID, Collection<Address> destinations, long initialSequenceNumber, boolean deliverToMyself)
messageID
- the message IDdestinations
- the destination setinitialSequenceNumber
- the initial sequence numberdeliverToMyself
- true if *this* member is in destination sent, false otherwisepublic long addPropose(MessageID messageID, Address from, long sequenceNumber)
messageID
- the message IDfrom
- the originator of the proposesequenceNumber
- the proposed sequence numberpublic boolean markSent(MessageID messageID)
messageID
- the message IDpublic Set<Address> getDestination(MessageID messageID)
messageID
- the message IDpublic void clear()
public Collection<MessageID> getPendingMessageIDs()
public long removeLeavers(MessageID messageID, Collection<Address> leavers)
Copyright © 2020 JBoss, a division of Red Hat. All rights reserved.