Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/9181bb97 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/9181bb97 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/9181bb97 Branch: refs/heads/camel-2.17.x Commit: 9181bb97c48d5b06bc76e82a3fbe3346b69cd5f9 Parents: ce9d85c Author: Andrea Cosentino <anco...@gmail.com> Authored: Thu May 12 13:43:59 2016 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Thu May 12 13:43:59 2016 +0200 ---------------------------------------------------------------------- .../camel/component/nats/NatsConfiguration.java | 2 +- .../apache/camel/component/nats/NatsConsumer.java | 16 +++++++++------- 2 files changed, 10 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/9181bb97/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConfiguration.java b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConfiguration.java index 6ebc4f2..260d1a7 100644 --- a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConfiguration.java +++ b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConfiguration.java @@ -198,7 +198,7 @@ public class NatsConfiguration { this.poolSize = poolSize; } - private static <T> void addPropertyIfNotNull(Properties props, String key, T value) { + private static <T> void addPropertyIfNotNull(Properties props, String key, T value) { if (value != null) { props.put(key, value); } http://git-wip-us.apache.org/repos/asf/camel/blob/9181bb97/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java index 85a5b85..fbcfa14 100644 --- a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java +++ b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java @@ -96,14 +96,14 @@ public class NatsConsumer extends DefaultConsumer { } public boolean isSubscribed() { - return subscribed; - } + return subscribed; + } - public void setSubscribed(boolean subscribed) { - this.subscribed = subscribed; - } + public void setSubscribed(boolean subscribed) { + this.subscribed = subscribed; + } - class NatsConsumingTask implements Runnable { + class NatsConsumingTask implements Runnable { private final Connection connection; private final NatsConfiguration configuration; @@ -133,7 +133,9 @@ public class NatsConsumer extends DefaultConsumer { } catch (Throwable e) { getExceptionHandler().handleException("Error during processing", e); } - if (connection.getSubscriptionCount() > 0) setSubscribed(true); + if (connection.getSubscriptionCount() > 0) { + setSubscribed(true); + } } }
