X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Feos-dom-akka%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Feos%2Fakka%2Fbootstrap%2FEOSMain.java;h=4fba4befb9a355fede1bea3bf2730022d9a36665;hb=8bc6af2b8238c8df18c589267aeda163f439b4a7;hp=9e646fa5c7e9753fe379504ddbb2229357230133;hpb=684673104adccd504e394e01a852a06d42047af0;p=controller.git diff --git a/opendaylight/md-sal/eos-dom-akka/src/main/java/org/opendaylight/controller/eos/akka/bootstrap/EOSMain.java b/opendaylight/md-sal/eos-dom-akka/src/main/java/org/opendaylight/controller/eos/akka/bootstrap/EOSMain.java index 9e646fa5c7..4fba4befb9 100644 --- a/opendaylight/md-sal/eos-dom-akka/src/main/java/org/opendaylight/controller/eos/akka/bootstrap/EOSMain.java +++ b/opendaylight/md-sal/eos-dom-akka/src/main/java/org/opendaylight/controller/eos/akka/bootstrap/EOSMain.java @@ -24,7 +24,7 @@ import org.opendaylight.controller.eos.akka.owner.checker.OwnerStateChecker; import org.opendaylight.controller.eos.akka.owner.checker.command.StateCheckerCommand; import org.opendaylight.controller.eos.akka.owner.supervisor.IdleSupervisor; import org.opendaylight.controller.eos.akka.owner.supervisor.command.OwnerSupervisorCommand; -import org.opendaylight.controller.eos.akka.registry.candidate.CandidateRegistry; +import org.opendaylight.controller.eos.akka.registry.candidate.CandidateRegistryInit; import org.opendaylight.controller.eos.akka.registry.candidate.command.CandidateRegistryCommand; import org.opendaylight.controller.eos.akka.registry.listener.type.EntityTypeListenerRegistry; import org.opendaylight.controller.eos.akka.registry.listener.type.command.TypeListenerRegistryCommand; @@ -42,7 +42,7 @@ public final class EOSMain extends AbstractBehavior { final String role = Cluster.get(context.getSystem()).selfMember().getRoles().iterator().next(); listenerRegistry = context.spawn(EntityTypeListenerRegistry.create(role), "ListenerRegistry"); - candidateRegistry = context.spawn(CandidateRegistry.create(), "CandidateRegistry"); + candidateRegistry = context.spawn(CandidateRegistryInit.create(), "CandidateRegistry"); ownerStateChecker = context.spawn(OwnerStateChecker.create(role), "OwnerStateChecker"); final ClusterSingleton clusterSingleton = ClusterSingleton.get(context.getSystem());