X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fnotifications%2FRoleChangeNotifier.java;fp=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fnotifications%2FRoleChangeNotifier.java;h=01f3827da78685e7e1312d7016f3e2015d0d7156;hp=bb4ad65f161f11bb57e5d263cdc17b41a2e0bc57;hb=544f0ea584563a7398111d74eb7e89140ac02613;hpb=aee1af5ece7434962324e27ac379f035c3ca8a64 diff --git a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/notifications/RoleChangeNotifier.java b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/notifications/RoleChangeNotifier.java index bb4ad65f16..01f3827da7 100644 --- a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/notifications/RoleChangeNotifier.java +++ b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/notifications/RoleChangeNotifier.java @@ -72,9 +72,8 @@ public class RoleChangeNotifier extends AbstractUntypedActor implements AutoClos } - } else if (message instanceof RoleChanged) { + } else if (message instanceof RoleChanged roleChanged) { // this message is sent by RaftActor. Notify registered listeners when this message is received. - RoleChanged roleChanged = (RoleChanged) message; LOG.info("RoleChangeNotifier for {} , received role change from {} to {}", memberId, roleChanged.getOldRole(), roleChanged.getNewRole()); @@ -86,10 +85,10 @@ public class RoleChangeNotifier extends AbstractUntypedActor implements AutoClos for (ActorRef listener: registeredListeners.values()) { listener.tell(latestRoleChangeNotification, getSelf()); } - } else if (message instanceof LeaderStateChanged) { - latestLeaderStateChanged = (LeaderStateChanged)message; + } else if (message instanceof LeaderStateChanged leaderStateChanged) { + latestLeaderStateChanged = leaderStateChanged; - for (ActorRef listener: registeredListeners.values()) { + for (ActorRef listener : registeredListeners.values()) { listener.tell(latestLeaderStateChanged, getSelf()); } } else {