Repository: camel Updated Branches: refs/heads/camel-2.17.x 0de81d1e0 -> 9181bb97c
CAMEL-9962: Add a field in the consumer to define if it subscribed to the topic or not Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/ce9d85cd Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ce9d85cd Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ce9d85cd Branch: refs/heads/camel-2.17.x Commit: ce9d85cd1bcbc83da00df8fcb939a8c78cc6ca14 Parents: 0de81d1 Author: Andrea Cosentino <anco...@gmail.com> Authored: Thu May 12 13:41:21 2016 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Thu May 12 13:41:21 2016 +0200 ---------------------------------------------------------------------- .../apache/camel/component/nats/NatsConfiguration.java | 2 +- .../org/apache/camel/component/nats/NatsConsumer.java | 12 +++++++++++- 2 files changed, 12 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/ce9d85cd/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 260d1a7..6ebc4f2 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/ce9d85cd/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 9c8a29d..85a5b85 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 @@ -36,6 +36,7 @@ public class NatsConsumer extends DefaultConsumer { private ExecutorService executor; private Connection connection; private int sid; + private boolean subscribed; public NatsConsumer(NatsEndpoint endpoint, Processor processor) { super(endpoint, processor); @@ -94,7 +95,15 @@ public class NatsConsumer extends DefaultConsumer { return connection; } - class NatsConsumingTask implements Runnable { + public boolean isSubscribed() { + return subscribed; + } + + public void setSubscribed(boolean subscribed) { + this.subscribed = subscribed; + } + + class NatsConsumingTask implements Runnable { private final Connection connection; private final NatsConfiguration configuration; @@ -124,6 +133,7 @@ public class NatsConsumer extends DefaultConsumer { } catch (Throwable e) { getExceptionHandler().handleException("Error during processing", e); } + if (connection.getSubscriptionCount() > 0) setSubscribed(true); } }
