X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Feos-dom-akka%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Feos%2Fakka%2Fbootstrap%2FEOSMain.java;h=4fba4befb9a355fede1bea3bf2730022d9a36665;hp=54f9a6b1487bf9657a049d53910f2b6c9bca11d9;hb=8bc6af2b8238c8df18c589267aeda163f439b4a7;hpb=e1e6d8e34fd4c5c5c07c7a8063ffa94a8dbe2062 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 54f9a6b148..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 @@ -22,9 +22,9 @@ import org.opendaylight.controller.eos.akka.bootstrap.command.RunningContext; import org.opendaylight.controller.eos.akka.bootstrap.command.Terminate; 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.OwnerSyncer; +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,12 +42,12 @@ 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()); // start the initial sync behavior that switches to the regular one after syncing - ownerSupervisor = clusterSingleton.init(SingletonActor.of(OwnerSyncer.create(), "OwnerSupervisor")); + ownerSupervisor = clusterSingleton.init(SingletonActor.of(IdleSupervisor.create(), "OwnerSupervisor")); } public static Behavior create() { @@ -72,4 +72,4 @@ public final class EOSMain extends AbstractBehavior { request.getReplyTo().tell(Empty.getInstance()); return Behaviors.stopped(); } -} +} \ No newline at end of file