You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2023/02/27 14:50:36 UTC
[camel] 02/02: CAMEL-19060: avoid extra unnecessary work when copying the messages
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 0f25205251d05fb2e12eee1dc95b7ad43fddc350
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Feb 15 13:23:16 2023 +0100
CAMEL-19060: avoid extra unnecessary work when copying the messages
- Copying the body and headers is performed by the Message class
---
.../org/apache/camel/impl/engine/DefaultUnitOfWork.java | 13 +------------
1 file changed, 1 insertion(+), 12 deletions(-)
diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java
index 3f1ee3d2bfb..48b32e9c4ee 100644
--- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java
+++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java
@@ -102,18 +102,7 @@ public class DefaultUnitOfWork implements UnitOfWork {
this.exchange = exchange;
if (allowUseOriginalMessage) {
- // special for JmsMessage as it can cause it to loose headers later.
- if (exchange.getIn().getClass().getName().equals("org.apache.camel.component.jms.JmsMessage")) {
- this.originalInMessage = new DefaultMessage(context);
- this.originalInMessage.setBody(exchange.getIn().getBody());
- this.originalInMessage.getHeaders().putAll(exchange.getIn().getHeaders());
- } else {
- this.originalInMessage = exchange.getIn().copy();
- }
- // must preserve exchange on the original in message
- if (this.originalInMessage instanceof MessageSupport) {
- ((MessageSupport) this.originalInMessage).setExchange(exchange);
- }
+ this.originalInMessage = exchange.getIn().copy();
}
// inject breadcrumb header if enabled