X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fexample%2FExampleRoleChangeListener.java;h=1676a41c56d7f9c2cfe81a7fc9e46c6828c8d721;hb=1e80b656857bf829d8ae3cae21b0b726190b96ea;hp=c0ee09536761847706a59b5c4be9ff3e2127ab23;hpb=a469dbcec569cc972df0cd57cf725a2173d2604a;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/example/ExampleRoleChangeListener.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/example/ExampleRoleChangeListener.java index c0ee095367..1676a41c56 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/example/ExampleRoleChangeListener.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/example/ExampleRoleChangeListener.java @@ -1,10 +1,8 @@ package org.opendaylight.controller.cluster.example; -import akka.actor.Actor; import akka.actor.ActorRef; import akka.actor.Cancellable; import akka.actor.Props; -import akka.japi.Creator; import java.util.HashMap; import java.util.Map; import java.util.concurrent.TimeUnit; @@ -46,12 +44,7 @@ public class ExampleRoleChangeListener extends AbstractUntypedActor implements A } public static Props getProps(final String memberName) { - return Props.create(new Creator() { - @Override - public Actor create() throws Exception { - return new ExampleRoleChangeListener(memberName); - } - }); + return Props.create(ExampleRoleChangeListener.class, memberName); } @Override