X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-remoterpc-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fremote%2Frpc%2FTerminationMonitor.java;h=c52ba2a747bfc45899413efe0cd5eb014db57b1a;hp=a90f1e1ed251204d6d3e4a45b6516bb783dbb41a;hb=5b66dd8f5e3467a07e77b20fe696b29993ce5565;hpb=11e9ade9af527aba7faeb633d3c9c7552fd09d2d diff --git a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/TerminationMonitor.java b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/TerminationMonitor.java index a90f1e1ed2..c52ba2a747 100644 --- a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/TerminationMonitor.java +++ b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/TerminationMonitor.java @@ -10,25 +10,24 @@ package org.opendaylight.controller.remote.rpc; import akka.actor.Terminated; import akka.actor.UntypedActor; -import akka.event.Logging; -import akka.event.LoggingAdapter; -import org.opendaylight.controller.remote.rpc.messages.Monitor; +import org.opendaylight.controller.cluster.common.actor.Monitor; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; -public class TerminationMonitor extends UntypedActor{ - protected final LoggingAdapter LOG = - Logging.getLogger(getContext().system(), this); +public class TerminationMonitor extends UntypedActor { + private static final Logger LOG = LoggerFactory.getLogger(TerminationMonitor.class); - public TerminationMonitor(){ - LOG.info("Created TerminationMonitor"); + public TerminationMonitor() { + LOG.debug("Created TerminationMonitor"); } @Override public void onReceive(Object message) throws Exception { - if(message instanceof Terminated){ + if (message instanceof Terminated) { Terminated terminated = (Terminated) message; LOG.debug("Actor terminated : {}", terminated.actor()); - }else if(message instanceof Monitor){ - Monitor monitor = (Monitor) message; - getContext().watch(monitor.getActorRef()); + } else if (message instanceof Monitor) { + Monitor monitor = (Monitor) message; + getContext().watch(monitor.getActorRef()); } } }