public class DeliveryManagerImpl extends 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
|
List<DeliveryManagerImpl.MessageInfo> |
getAllMessages() |
List<Message> |
getNextMessagesToDeliver()
returns an ordered list with the messages to be deliver.
|
SequenceNumberManager |
getSequenceNumberManager() |
long |
getViewId() |
Collection<Address> |
handleView(View newView)
Updates the current view in use and returns a
Collection with the members that left the cluster. |
public final Collection<Address> handleView(View newView)
Collection
with the members that left the cluster.public long getViewId()
-1
if no view is installed yet.public List<Message> getNextMessagesToDeliver() throws InterruptedException
DeliveryManager
getNextMessagesToDeliver
in interface DeliveryManager
InterruptedException
- if it is interruptedpublic List<DeliveryManagerImpl.MessageInfo> getAllMessages()
public void clear()
public SequenceNumberManager getSequenceNumberManager()
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.