X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fakka%2Fimpl%2FActorSystemProviderImpl.java;h=6e805b33d7893045b431f3314cd18525a3bce5e4;hp=0d43250f5d42c2c67370f8e83d01f3aeaa82bb9f;hb=e8215aef8cf2475512d7601fdaebcb1294e93fc7;hpb=e66759266dc43d5f58b2837aca5047b42c205e4a diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/akka/impl/ActorSystemProviderImpl.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/akka/impl/ActorSystemProviderImpl.java index 0d43250f5d..6e805b33d7 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/akka/impl/ActorSystemProviderImpl.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/akka/impl/ActorSystemProviderImpl.java @@ -11,6 +11,7 @@ import akka.actor.ActorSystem; import akka.actor.Props; import com.typesafe.config.Config; import java.util.concurrent.TimeUnit; +import java.util.concurrent.TimeoutException; import org.opendaylight.controller.cluster.ActorSystemProvider; import org.opendaylight.controller.cluster.ActorSystemProviderListener; import org.opendaylight.controller.cluster.common.actor.QuarantinedMonitorActor; @@ -51,14 +52,8 @@ public class ActorSystemProviderImpl implements ActorSystemProvider, AutoCloseab } @Override - @SuppressWarnings("checkstyle:IllegalCatch") - public void close() { + public void close() throws TimeoutException, InterruptedException { LOG.info("Shutting down ActorSystem"); - - try { - Await.result(actorSystem.terminate(), FiniteDuration.create(10, TimeUnit.SECONDS)); - } catch (final Exception e) { - LOG.warn("Error awaiting actor termination", e); - } + Await.result(actorSystem.terminate(), FiniteDuration.create(10, TimeUnit.SECONDS)); } }