Package | Description |
---|---|
org.jgroups.protocols.tom |
Modifier and Type | Method and Description |
---|---|
MessageID |
ToaHeader.getMessageID() |
Modifier and Type | Method and Description |
---|---|
Collection<MessageID> |
SenderManager.getPendingMessageIDs() |
Modifier and Type | Method and Description |
---|---|
void |
SenderManager.addNewMessageToSend(MessageID messageID,
Collection<Address> destinations,
long initialSequenceNumber,
boolean deliverToMyself)
Add a new message sent
|
long |
SenderManager.addPropose(MessageID messageID,
Address from,
long sequenceNumber)
Add a propose from a member in destination set
|
int |
MessageID.compareTo(MessageID other) |
static ToaHeader |
ToaHeader.createSingleDestinationHeader(MessageID messageID) |
Set<Address> |
SenderManager.getDestination(MessageID messageID)
obtains the destination set of a message
|
boolean |
SenderManager.markSent(MessageID messageID)
Mark the message as sent
|
static ToaHeader |
ToaHeader.newDataMessageHeader(MessageID messageID,
long viewId) |
static ToaHeader |
ToaHeader.newFinalMessageHeader(MessageID messageID,
long sequenceNumber) |
static ToaHeader |
ToaHeader.newProposeMessageHeader(MessageID messageID,
long sequencerNumber) |
long |
SenderManager.removeLeavers(MessageID messageID,
Collection<Address> leavers) |
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.