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:26:08 UTC
[camel] branch master updated: Update
TemporaryQueueReplyManager.java (#2490)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new ee8e617 Update TemporaryQueueReplyManager.java (#2490)
ee8e617 is described below
commit ee8e6176a80ec905ef00032dccf6ee2a1fe89060
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);
}
/**