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 and Description
static class	DeliveryManagerImpl.MessageInfo Keeps the state of a message

Constructor Summary

Constructors

Constructor and Description
DeliveryManagerImpl()

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DeliveryManagerImpl

public DeliveryManagerImpl()

Method Detail

handleView

public final java.util.Collection<Address> handleView(View newView)

Updates the current view in use and returns a Collection 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 interface DeliveryManager

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()