public class DeliveryManagerImpl extends java.lang.Object implements DeliveryManager
Modifier and Type | Class and Description |
---|---|
static class |
DeliveryManagerImpl.MessageInfo
Keeps the state of a message
|
Constructor and Description |
---|
DeliveryManagerImpl() |
Modifier and Type | Method and Description |
---|---|
void |
clear()
remove all the pending messages
|
java.util.List<DeliveryManagerImpl.MessageInfo> |
getAllMessages() |
java.util.List<Message> |
getNextMessagesToDeliver()
returns an ordered list with the messages to be deliver.
|
SequenceNumberManager |
getSequenceNumberManager() |
long |
getViewId() |
java.util.Collection<Address> |
handleView(View newView)
Updates the current view in use and returns a
Collection with the members that left the cluster. |
public final java.util.Collection<Address> handleView(View newView)
Collection
with the members that left the cluster.public long getViewId()
-1
if no view is installed yet.public java.util.List<Message> getNextMessagesToDeliver() throws java.lang.InterruptedException
DeliveryManager
getNextMessagesToDeliver
in interface DeliveryManager
java.lang.InterruptedException
- if it is interruptedpublic java.util.List<DeliveryManagerImpl.MessageInfo> getAllMessages()
public void clear()
public SequenceNumberManager getSequenceNumberManager()
Copyright © 1998-2020 Red Hat. All Rights Reserved.