X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fshardmanager%2FShardManagerInfo.java;h=8577a5914c0389905f9f55d4fff8fb496ac91cff;hb=HEAD;hp=219c5bb4958c6da4254eeff397c8b84f71c16b65;hpb=b5cb353e3553a39f576c284119af75ffa5ea66a9;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardManagerInfo.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardManagerInfo.java index 219c5bb495..8577a5914c 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardManagerInfo.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardManagerInfo.java @@ -5,12 +5,13 @@ * 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.cluster.datastore.shardmanager; +import static java.util.Objects.requireNonNull; + import akka.actor.ActorRef; import akka.pattern.Patterns; -import com.google.common.base.Preconditions; +import com.google.common.base.Throwables; import java.util.List; import org.opendaylight.controller.cluster.access.concepts.MemberName; import org.opendaylight.controller.cluster.datastore.identifiers.ShardIdentifier; @@ -37,8 +38,8 @@ final class ShardManagerInfo extends AbstractMXBean implements ShardManagerInfoM ShardManagerInfo(final ActorRef shardManager, final MemberName memberName, final String name, final String mxBeanType) { super(name, mxBeanType, JMX_CATEGORY_SHARD_MANAGER); - this.shardManager = Preconditions.checkNotNull(shardManager); - this.memberName = Preconditions.checkNotNull(memberName); + this.shardManager = requireNonNull(shardManager); + this.memberName = requireNonNull(memberName); } @SuppressWarnings({"unchecked", "checkstyle:IllegalCatch"}) @@ -47,10 +48,9 @@ final class ShardManagerInfo extends AbstractMXBean implements ShardManagerInfoM try { return (List) Await.result( Patterns.ask(shardManager, GetLocalShardIds.INSTANCE, ASK_TIMEOUT_MILLIS), Duration.Inf()); - } catch (RuntimeException e) { - throw e; } catch (Exception e) { - throw new RuntimeException(e); + Throwables.throwIfUnchecked(e); + throw new IllegalStateException(e); } } @@ -80,10 +80,9 @@ final class ShardManagerInfo extends AbstractMXBean implements ShardManagerInfoM try { Await.result(Patterns.ask(shardManager, new SwitchShardBehavior(shardId, state, term), ASK_TIMEOUT_MILLIS), Duration.Inf()); - } catch (RuntimeException e) { - throw e; } catch (Exception e) { - throw new RuntimeException(e); + Throwables.throwIfUnchecked(e); + throw new IllegalStateException(e); } break; case Candidate: