public class DeliveryManagerImpl extends Object implements DeliveryManager
Constructor and Description |
---|
DeliveryManagerImpl() |
Modifier and Type | Method and Description |
---|---|
void |
addNewMessageToDeliver(MessageID messageID,
Message message,
long sequenceNumber)
Add a new group message to be deliver
|
void |
clear()
remove all the pending messages
|
void |
deliverSingleDestinationMessage(Message msg)
delivers a message that has only as destination member this node
|
Set<org.jgroups.protocols.tom.DeliveryManagerImpl.MessageInfo> |
getMessageSet()
It is used for testing (see the messages in JMX)
|
List<Message> |
getNextMessagesToDeliver()
returns an ordered list with the messages to be deliver.
|
void |
markReadyToDeliver(MessageID messageID,
long finalSequenceNumber)
marks the message as ready to deliver and set the final sequence number (to be ordered)
|
void |
removeLeavers(Collection<Address> leavers) |
public void addNewMessageToDeliver(MessageID messageID, Message message, long sequenceNumber)
messageID
- the message IDmessage
- the message (needed to be deliver later)sequenceNumber
- the initial sequence numberpublic void markReadyToDeliver(MessageID messageID, long finalSequenceNumber)
messageID
- the message IDfinalSequenceNumber
- the final sequence numberpublic final void removeLeavers(Collection<Address> leavers)
public List<Message> getNextMessagesToDeliver() throws InterruptedException
DeliveryManager
getNextMessagesToDeliver
in interface DeliveryManager
InterruptedException
- if it is interruptedpublic void clear()
public void deliverSingleDestinationMessage(Message msg)
msg
- the messagepublic Set<org.jgroups.protocols.tom.DeliveryManagerImpl.MessageInfo> getMessageSet()
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.