+ } else if (message instanceof LeaderStateChanged leaderStateChanged) {
+ latestLeaderStateChanged = leaderStateChanged;
+
+ for (ActorRef listener : registeredListeners.values()) {
+ listener.tell(latestLeaderStateChanged, getSelf());
+ }
+ } else {
+ unknownMessage(message);