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 <davscl...@apache.org> Authored: Mon Apr 18 10:31:14 2016 +0200 Committer: Claus Ibsen <davscl...@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()); }
