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 classDeliveryManagerImpl.MessageInfoKeeps the state of a message
-
Constructor Summary
Constructors Constructor Description DeliveryManagerImpl()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclear()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.SequenceNumberManagergetSequenceNumberManager()longgetViewId()java.util.Collection<Address>handleView(View newView)Updates the current view in use and returns aCollectionwith 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 aCollectionwith the members that left the cluster.
-
getViewId
public long getViewId()
- Returns:
- the current view id or
-1if no view is installed yet.
-
getNextMessagesToDeliver
public java.util.List<Message> getNextMessagesToDeliver() throws java.lang.InterruptedException
Description copied from interface:DeliveryManagerreturns an ordered list with the messages to be deliver. This method blocks if no messages are ready to be deliver- Specified by:
getNextMessagesToDeliverin 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()
-
-