You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2016/04/18 10:31:24 UTC
[2/2] camel git commit: Preserve headers
Preserve headers
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/bdf10d54
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/bdf10d54
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/bdf10d54
Branch: refs/heads/master
Commit: bdf10d5447e46f7d36001c3001b46a4cc454dcf5
Parents: 4fc5724
Author: Claus Ibsen <da...@apache.org>
Authored: Mon Apr 18 10:31:14 2016 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Mon Apr 18 10:31:14 2016 +0200
----------------------------------------------------------------------
.../org/apache/camel/component/cassandra/CassandraProducer.java | 3 +++
.../main/java/org/apache/camel/component/cmis/CMISProducer.java | 3 +++
2 files changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/bdf10d54/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraProducer.java b/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraProducer.java
index be91c34..1b03c25 100644
--- a/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraProducer.java
+++ b/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraProducer.java
@@ -165,6 +165,9 @@ public class CassandraProducer extends DefaultProducer {
}
public void process(Exchange exchange) throws Exception {
+ // copy the header of in message to the out message
+ exchange.getOut().copyFrom(exchange.getIn());
+
ResultSet resultSet = execute(exchange.getIn());
getEndpoint().fillMessage(resultSet, exchange.getOut());
}
http://git-wip-us.apache.org/repos/asf/camel/blob/bdf10d54/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISProducer.java b/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISProducer.java
index dcc9f29..4538c0b 100644
--- a/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISProducer.java
+++ b/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISProducer.java
@@ -56,6 +56,9 @@ public class CMISProducer extends DefaultProducer {
public void process(Exchange exchange) throws Exception {
CmisObject cmisObject = createNode(exchange);
LOG.debug("Created node with id: {}", cmisObject.getId());
+
+ // copy the header of in message to the out message
+ exchange.getOut().copyFrom(exchange.getIn());
exchange.getOut().setBody(cmisObject.getId());
}