Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/ed4d1fa8 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ed4d1fa8 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ed4d1fa8 Branch: refs/heads/master Commit: ed4d1fa896e3ca1e80b98c42ccdf051b1b24e90a Parents: 939a895 Author: Andrea Cosentino <anco...@gmail.com> Authored: Tue Jan 19 15:12:58 2016 +0100 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Tue Jan 19 15:12:58 2016 +0100 ---------------------------------------------------------------------- .../java/org/apache/camel/component/nats/NatsConsumer.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/ed4d1fa8/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 c364277..7b77b16 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 @@ -67,10 +67,10 @@ public class NatsConsumer extends DefaultConsumer { connection.flush(); try { - connection.unsubscribe(sid); - } catch (Exception e) { - getExceptionHandler().handleException("Error during unsubscribing", e); - } + connection.unsubscribe(sid); + } catch (Exception e) { + getExceptionHandler().handleException("Error during unsubscribing", e); + } LOG.debug("Stopping Nats Consumer"); if (executor != null) {
