Package org.jgroups.protocols.tom
Class DeliveryManagerImpl
- java.lang.Object
-
- org.jgroups.protocols.tom.DeliveryManagerImpl
-
- All Implemented Interfaces:
DeliveryManager
public class DeliveryManagerImpl extends java.lang.Object implements DeliveryManager
The implementation of the Delivery Manager- Since:
- 3.1
- Author:
- Pedro Ruivo
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
DeliveryManagerImpl.MessageInfo
Keeps the state of a message
-
Constructor Summary
Constructors Constructor Description DeliveryManagerImpl()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clear()
remove all the pending messagesjava.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 aCollection
with the members that left the cluster.
-
-
-
Method Detail
-
handleView
public final java.util.Collection<Address> handleView(View newView)
Updates the current view in use and returns aCollection
with the members that left the cluster.
-
getViewId
public long getViewId()
- Returns:
- the current view id or
-1
if no view is installed yet.
-
getNextMessagesToDeliver
public java.util.List<Message> getNextMessagesToDeliver() throws java.lang.InterruptedException
Description copied from interface:DeliveryManager
returns an ordered list with the messages to be deliver. This method blocks if no messages are ready to be deliver- Specified by:
getNextMessagesToDeliver
in interfaceDeliveryManager
- Returns:
- a list of messages to deliver
- Throws:
java.lang.InterruptedException
- if it is interrupted
-
getAllMessages
public java.util.List<DeliveryManagerImpl.MessageInfo> getAllMessages()
-
clear
public void clear()
remove all the pending messages
-
getSequenceNumberManager
public SequenceNumberManager getSequenceNumberManager()
-
-