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

Constructor Summary

Constructors

Constructor and Description
DeliveryManagerImpl()

Method Summary

Modifier and Type	Method and Description
long	addLocalMessageToDeliver(MessageID messageID, Message message, ToaHeader header)
long	addRemoteMessageToDeliver(MessageID messageID, Message message, long remoteSequenceNumber)
void	clear() remove all the pending messages
void	deliverSingleDestinationMessage(Message msg, MessageID messageID) delivers a message that has only as destination member this node
java.util.Set<org.jgroups.protocols.tom.DeliveryManagerImpl.MessageInfo>	getMessageSet() It is used for testing (see the messages in JMX)
java.util.List<Message>	getNextMessagesToDeliver() returns an ordered list with the messages to be deliver.
void	markReadyToDeliver(MessageID messageID, long finalSequenceNumber) marks the message as ready to deliver and set the final sequence number (to be ordered)
void	removeLeavers(java.util.Collection<Address> leavers)
void	updateSequenceNumber(long sequenceNumber)

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

addLocalMessageToDeliver

public long addLocalMessageToDeliver(MessageID messageID,
                                     Message message,
                                     ToaHeader header)

addRemoteMessageToDeliver

public long addRemoteMessageToDeliver(MessageID messageID,
                                      Message message,
                                      long remoteSequenceNumber)

updateSequenceNumber

public void updateSequenceNumber(long sequenceNumber)

markReadyToDeliver

public void markReadyToDeliver(MessageID messageID,
                               long finalSequenceNumber)

marks the message as ready to deliver and set the final sequence number (to be ordered)

Parameters:

messageID - the message ID

finalSequenceNumber - the final sequence number

removeLeavers

public final void removeLeavers(java.util.Collection<Address> leavers)

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

clear

public void clear()

remove all the pending messages

deliverSingleDestinationMessage

public void deliverSingleDestinationMessage(Message msg,
                                            MessageID messageID)

delivers a message that has only as destination member this node

Parameters:

msg - the message

getMessageSet

public java.util.Set<org.jgroups.protocols.tom.DeliveryManagerImpl.MessageInfo> getMessageSet()

It is used for testing (see the messages in JMX)

Returns:

unmodifiable set of messages