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 2018/08/22 10:28:19 UTC
[camel] branch camel-2.21.x updated: Update
TemporaryQueueReplyManager.java (#2490)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-2.21.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-2.21.x by this push:
new ba1fa6a Update TemporaryQueueReplyManager.java (#2490)
ba1fa6a is described below
commit ba1fa6a0a7ea9d358509a91d598f448e95a4f1e6
Author: valdisa <va...@gmail.com>
AuthorDate: Wed Aug 22 11:26:05 2018 +0100
Update TemporaryQueueReplyManager.java (#2490)
---
.../camel/component/rabbitmq/reply/TemporaryQueueReplyManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/reply/TemporaryQueueReplyManager.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/reply/TemporaryQueueReplyManager.java
index 842d43e..760cc47 100644
--- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/reply/TemporaryQueueReplyManager.java
+++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/reply/TemporaryQueueReplyManager.java
@@ -136,7 +136,7 @@ public class TemporaryQueueReplyManager extends ReplyManagerSupport {
* Bind consumer to channel
*/
private void start() throws IOException {
- tag = channel.basicConsume(getReplyTo(), endpoint.isAutoAck(), this);
+ tag = channel.basicConsume(getReplyTo(), true, this);
}
/**