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 TypeMethodDescriptionbooleanWhether a node on the cluster has already been started as a leader.voidstart()Start the node as a leader in the cluster.voidstart(List<Consumer<RetryHandlerStatus>> consumers) Start the cluster service with a list of consumers for retry handler status eventsvoidstop()Stop the node as a leader in the cluster.
-
Method Details
-
start
void start()Start the node as a leader in the cluster. -
start
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.
-