Package | Description |
---|---|
org.jgroups.protocols.tom |
Modifier and Type | Method and Description |
---|---|
MessageID |
ToaHeader.getMessageID() |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<MessageID> |
SenderManager.getPendingMessageIDs() |
Modifier and Type | Method and Description |
---|---|
long |
DeliveryManagerImpl.addLocalMessageToDeliver(MessageID messageID,
Message message,
ToaHeader header) |
void |
SenderManager.addNewMessageToSend(MessageID messageID,
java.util.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
|
long |
DeliveryManagerImpl.addRemoteMessageToDeliver(MessageID messageID,
Message message,
long remoteSequenceNumber) |
int |
MessageID.compareTo(MessageID other) |
static ToaHeader |
ToaHeader.createSingleDestinationHeader(MessageID messageID) |
void |
DeliveryManagerImpl.deliverSingleDestinationMessage(Message msg,
MessageID messageID)
delivers a message that has only as destination member this node
|
java.util.Set<Address> |
SenderManager.getDestination(MessageID messageID)
obtains the destination set of a message
|
void |
DeliveryManagerImpl.markReadyToDeliver(MessageID messageID,
long finalSequenceNumber)
marks the message as ready to deliver and set the final sequence number (to be ordered)
|
boolean |
SenderManager.markSent(MessageID messageID)
Mark the message as sent
|
static ToaHeader |
ToaHeader.newDataMessageHeader(MessageID messageID,
java.util.Collection<Address> destinations) |
static ToaHeader |
ToaHeader.newFinalMessageHeader(MessageID messageID,
long sequenceNumber) |
static ToaHeader |
ToaHeader.newProposeMessageHeader(MessageID messageID,
long sequencerNumber) |
long |
SenderManager.removeLeavers(MessageID messageID,
java.util.Collection<Address> leavers) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.