X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fcommon%2Factor%2FCommonConfig.java;h=d57134d11dbddbaf051af31cee6cb7f9a3fcfed7;hp=746ef4ebb1385387b2c2167e82d148e8cab82a23;hb=81674d6fd50b419b868d0851062e23f34b34557d;hpb=dbff1740fe3e5a1f007c183ecc27d25915866945 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 746ef4ebb1..d57134d11d 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,15 +7,13 @@ */ package org.opendaylight.controller.cluster.common.actor; - import com.google.common.base.Preconditions; import com.typesafe.config.Config; -import scala.concurrent.duration.Duration; -import scala.concurrent.duration.FiniteDuration; - 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 { @@ -43,8 +41,8 @@ public class CommonConfig extends AbstractConfig { return get().getString(TAG_ACTOR_SYSTEM_NAME); } - public boolean isMetricCaptureEnabled(){ - if (cachedMetricCaptureEnableFlag != null){ + public boolean isMetricCaptureEnabled() { + if (cachedMetricCaptureEnableFlag != null) { return cachedMetricCaptureEnableFlag; } @@ -65,7 +63,7 @@ public class CommonConfig extends AbstractConfig { return cachedMailBoxCapacity; } - final String PATH = new StringBuilder(TAG_MAILBOX).append(".").append(TAG_MAILBOX_CAPACITY).toString(); + final String PATH = TAG_MAILBOX + "." + TAG_MAILBOX_CAPACITY; cachedMailBoxCapacity = get().hasPath(PATH) ? get().getInt(PATH) : DEFAULT_MAILBOX_CAPACITY; @@ -79,7 +77,7 @@ public class CommonConfig extends AbstractConfig { return cachedMailBoxPushTimeout; } - final String PATH = new StringBuilder(TAG_MAILBOX).append(".").append(TAG_MAILBOX_PUSH_TIMEOUT).toString(); + final String PATH = TAG_MAILBOX + "." + TAG_MAILBOX_PUSH_TIMEOUT; long timeout = get().hasPath(PATH) ? get().getDuration(PATH, TimeUnit.NANOSECONDS) @@ -89,7 +87,7 @@ public class CommonConfig extends AbstractConfig { return cachedMailBoxPushTimeout; } - public static class Builder> extends AbstractConfig.Builder{ + public static class Builder> extends AbstractConfig.Builder { public Builder(String actorSystemName) { super(actorSystemName); @@ -101,11 +99,13 @@ public class CommonConfig extends AbstractConfig { configHolder.put(TAG_MAILBOX, new HashMap()); } + @SuppressWarnings("unchecked") public T metricCaptureEnabled(boolean enabled) { configHolder.put(TAG_METRIC_CAPTURE_ENABLED, String.valueOf(enabled)); return (T)this; } + @SuppressWarnings("unchecked") public T mailboxCapacity(int capacity) { Preconditions.checkArgument(capacity > 0, "mailbox capacity must be >0"); @@ -114,7 +114,8 @@ public class CommonConfig extends AbstractConfig { return (T)this; } - public T mailboxPushTimeout(String timeout){ + @SuppressWarnings("unchecked") + public T mailboxPushTimeout(String timeout) { Duration pushTimeout = Duration.create(timeout); Preconditions.checkArgument(pushTimeout.isFinite(), "invalid value for mailbox push timeout");