X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-remoterpc-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fremote%2Frpc%2FTerminationMonitor.java;h=a79a4e45d421f2aad2f008e6a41d92ff115c1592;hb=HEAD;hp=6590941e39e85d638550e6f391dc11081fae52ea;hpb=0f02b7edeb1454c1a568f0f1b050757e7503ddf7;p=controller.git 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 6590941e39..a79a4e45d4 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 @@ -5,7 +5,6 @@ * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ - package org.opendaylight.controller.remote.rpc; import akka.actor.Terminated; @@ -21,12 +20,11 @@ public class TerminationMonitor extends UntypedAbstractActor { LOG.debug("Created TerminationMonitor"); } - @Override public void onReceive(Object message) { - if (message instanceof Terminated) { - Terminated terminated = (Terminated) message; + @Override + public void onReceive(final Object message) { + if (message instanceof Terminated terminated) { LOG.debug("Actor terminated : {}", terminated.actor()); - } else if (message instanceof Monitor) { - Monitor monitor = (Monitor) message; + } else if (message instanceof Monitor monitor) { getContext().watch(monitor.getActorRef()); } }