You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2015/01/04 07:55:47 UTC
[2/4] camel git commit: CAMEL-8200 Fix the issue of race condition in
JmsProducer for request/response messaging with thanks to Krzysztof
CAMEL-8200 Fix the issue of race condition in JmsProducer for request/response messaging with thanks to Krzysztof
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5832b06e
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5832b06e
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5832b06e
Branch: refs/heads/camel-2.13.x
Commit: 5832b06e7446b5719496068f826ff8eb1a1f697c
Parents: 3ca1a6d
Author: Willem Jiang <wi...@gmail.com>
Authored: Sun Jan 4 14:03:15 2015 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Sun Jan 4 14:12:16 2015 +0800
----------------------------------------------------------------------
.../src/main/java/org/apache/camel/component/jms/JmsProducer.java | 3 ---
1 file changed, 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/5832b06e/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java
index a30c4f3..0ad2949 100644
--- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java
+++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java
@@ -232,9 +232,6 @@ public class JmsProducer extends DefaultAsyncProducer {
doSend(true, destinationName, destination, messageCreator, messageSentCallback);
- // after sending then set the OUT message id to the JMSMessageID so its identical
- setMessageId(exchange);
-
// continue routing asynchronously (reply will be processed async when its received)
return false;
}