Repository: camel Updated Branches: refs/heads/master 8e11b7ace -> 9bee8ddc4
camel-nats: Adjust header names. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/9bee8ddc Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/9bee8ddc Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/9bee8ddc Branch: refs/heads/master Commit: 9bee8ddc4907729dd2724cdbaf0bf845118f639e Parents: 8e11b7a Author: Raúl Kripalani <[email protected]> Authored: Sun Mar 20 11:30:30 2016 +0000 Committer: Raúl Kripalani <[email protected]> Committed: Sun Mar 20 11:30:30 2016 +0000 ---------------------------------------------------------------------- .../main/java/org/apache/camel/component/nats/NatsConstants.java | 4 ++-- .../main/java/org/apache/camel/component/nats/NatsConsumer.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/9bee8ddc/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConstants.java ---------------------------------------------------------------------- diff --git a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConstants.java b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConstants.java index 1d38369..9bdee5d 100644 --- a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConstants.java +++ b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConstants.java @@ -18,6 +18,6 @@ package org.apache.camel.component.nats; public interface NatsConstants { - String NATS_MESSAGE_TIMESTAMP = "natsMessageTimestamp"; - String NATS_SUBSCRIBE_SID = "natsSubscribeSid"; + String NATS_MESSAGE_TIMESTAMP = "CamelNatsMessageTimestamp"; + String NATS_SUBSCRIPTION_ID = "CamelNatsSubscriptionId"; } http://git-wip-us.apache.org/repos/asf/camel/blob/9bee8ddc/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 7b77b16..9c8a29d 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 @@ -113,7 +113,7 @@ public class NatsConsumer extends DefaultConsumer { Exchange exchange = getEndpoint().createExchange(); exchange.getIn().setBody(msg); exchange.getIn().setHeader(NatsConstants.NATS_MESSAGE_TIMESTAMP, System.currentTimeMillis()); - exchange.getIn().setHeader(NatsConstants.NATS_SUBSCRIBE_SID, sid); + exchange.getIn().setHeader(NatsConstants.NATS_SUBSCRIPTION_ID, sid); try { processor.process(exchange); } catch (Exception e) {
