import org.opendaylight.controller.cluster.notifications.RegisterRoleChangeListenerReply;
import org.opendaylight.controller.cluster.notifications.RoleChangeNotification;
import scala.concurrent.Await;
import scala.concurrent.duration.FiniteDuration;
public class ExampleRoleChangeListener extends AbstractUntypedActor implements AutoCloseable{
<BUG>private static final String NOTIFIER_AKKA_URL = "akka.tcp://raft-test@127.0.0.1:2550/user/";
private Map<String, Boolean> notifierRegistrationStatus = new HashMap<>();</BUG>
private Cancellable registrationSchedule = null;
private static final FiniteDuration duration = new FiniteDuration(100, TimeUnit.MILLISECONDS);
private static final FiniteDuration schedulerDuration = new FiniteDuration(1, TimeUnit.SECONDS);

import org.opendaylight.controller.cluster.notifications.RegisterRoleChangeListenerReply;
import org.opendaylight.controller.cluster.notifications.RoleChangeNotification;
import scala.concurrent.Await;
import scala.concurrent.duration.FiniteDuration;
public class ExampleRoleChangeListener extends AbstractUntypedActor implements AutoCloseable{
private static final String NOTIFIER_AKKA_URL = "akka://raft-test@127.0.0.1:2550/user/";
private Map<String, Boolean> notifierRegistrationStatus = new HashMap<>();
private Cancellable registrationSchedule = null;
private static final FiniteDuration duration = new FiniteDuration(100, TimeUnit.MILLISECONDS);
private static final FiniteDuration schedulerDuration = new FiniteDuration(1, TimeUnit.SECONDS);
