This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new d5245ccd0ec9 CAMEL-26226: camel-cassandraql - remove the copy of the
in message onto itself in CassandraProducer (#29069)
d5245ccd0ec9 is described below
commit d5245ccd0ec9164167375444fe332e81d2806a5b
Author: Andrea Cosentino <[email protected]>
AuthorDate: Tue Nov 3 12:10:31 2026 +0100
CAMEL-26226: camel-cassandraql - remove the copy of the in message onto
itself in CassandraProducer (#29069)
Co-Authored-By: Claude Opus 5.5 <[email protected]>
---
.../java/org/apache/camel/component/cassandra/CassandraProducer.java | 3 ---
1 file changed, 3 deletions(-)
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 12e508d7094b..bb3cbe351d3a 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,9 +165,6 @@ public class CassandraProducer extends DefaultProducer {
@Override
public void process(Exchange exchange) throws Exception {
- // copy the header of in message to the out message
- exchange.getMessage().copyFrom(exchange.getIn());
-
ResultSet resultSet = execute(exchange.getIn());
getEndpoint().fillMessage(resultSet, exchange.getMessage());
}