Class 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 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
      • clear

        public void clear()
        remove all the pending messages