You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ra...@apache.org on 2016/03/20 12:30:40 UTC
camel git commit: camel-nats: Adjust header names.
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 <ra...@apache.org>
Authored: Sun Mar 20 11:30:30 2016 +0000
Committer: Raúl Kripalani <ra...@apache.org>
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) {