Interface RetryClusterService

All Known Implementing Classes:
DefaultRetryClusterService

public interface RetryClusterService
Used to keep track of start/stop behavior that determines node leadership in a cluster. This service is specifically responsible for setting up RetryHandler instances for any qualified NotificationStateRepository detected.
Author:
Jeff Fischer
  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    Whether a node on the cluster has already been started as a leader.
    void
    Start the node as a leader in the cluster.
    void
    Start the cluster service with a list of consumers for retry handler status events
    void
    Stop the node as a leader in the cluster.
  • Method Details

    • start

      void start()
      Start the node as a leader in the cluster.
    • start

      void start(@Nullable List<Consumer<RetryHandlerStatus>> consumers)
      Start the cluster service with a list of consumers for retry handler status events
      Parameters:
      consumers - consumers for retry handler status events. May be null.
    • isStarted

      boolean isStarted()
      Whether a node on the cluster has already been started as a leader.
      Returns:
      Whether a node on the cluster has already been started as a leader.
    • stop

      void stop()
      Stop the node as a leader in the cluster.