X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fcommon%2Factor%2FCommonConfig.java;fp=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fcommon%2Factor%2FCommonConfig.java;h=6a350afc8eed3e33a19fce622a2028c5752ecd02;hb=f23c0bb85435ad6b41baa2e551fa84c81a44349b;hp=d57134d11dbddbaf051af31cee6cb7f9a3fcfed7;hpb=e5ca6876ae3500543710d4c179ce2761c3cb4087;p=controller.git diff --git a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/common/actor/CommonConfig.java b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/common/actor/CommonConfig.java index d57134d11d..6a350afc8e 100644 --- a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/common/actor/CommonConfig.java +++ b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/common/actor/CommonConfig.java @@ -7,12 +7,12 @@ */ package org.opendaylight.controller.cluster.common.actor; -import com.google.common.base.Preconditions; +import static com.google.common.base.Preconditions.checkArgument; + import com.typesafe.config.Config; import java.util.HashMap; import java.util.Map; import java.util.concurrent.TimeUnit; -import scala.concurrent.duration.Duration; import scala.concurrent.duration.FiniteDuration; public class CommonConfig extends AbstractConfig { @@ -83,7 +83,7 @@ public class CommonConfig extends AbstractConfig { ? get().getDuration(PATH, TimeUnit.NANOSECONDS) : DEFAULT_MAILBOX_PUSH_TIMEOUT; - cachedMailBoxPushTimeout = new FiniteDuration(timeout, TimeUnit.NANOSECONDS); + cachedMailBoxPushTimeout = FiniteDuration.create(timeout, TimeUnit.NANOSECONDS); return cachedMailBoxPushTimeout; } @@ -107,7 +107,7 @@ public class CommonConfig extends AbstractConfig { @SuppressWarnings("unchecked") public T mailboxCapacity(int capacity) { - Preconditions.checkArgument(capacity > 0, "mailbox capacity must be >0"); + checkArgument(capacity > 0, "mailbox capacity must be >0"); Map boundedMailbox = (Map) configHolder.get(TAG_MAILBOX); boundedMailbox.put(TAG_MAILBOX_CAPACITY, capacity); @@ -116,8 +116,8 @@ public class CommonConfig extends AbstractConfig { @SuppressWarnings("unchecked") public T mailboxPushTimeout(String timeout) { - Duration pushTimeout = Duration.create(timeout); - Preconditions.checkArgument(pushTimeout.isFinite(), "invalid value for mailbox push timeout"); + checkArgument(FiniteDuration.create(timeout).isFinite(), "invalid value \"%s\" for mailbox push timeout", + timeout); Map boundedMailbox = (Map) configHolder.get(TAG_MAILBOX); boundedMailbox.put(TAG_MAILBOX_PUSH_TIMEOUT, timeout);