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/01/07 09:24:34 UTC
[camel] branch camel-2.20.x updated: CAMEL-12129: fix broken
integration test from CAMEL-12111
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-2.20.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-2.20.x by this push:
new f79949d CAMEL-12129: fix broken integration test from CAMEL-12111
f79949d is described below
commit f79949d8b8a4625358217e03c92c5dcfb46ccfec
Author: Jeremy Isikoff <ji...@yahoo.com>
AuthorDate: Sat Jan 6 23:05:42 2018 -0500
CAMEL-12129: fix broken integration test from CAMEL-12111
---
.../java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java
index c0aaa6d..1dd0491 100644
--- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java
+++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java
@@ -161,7 +161,8 @@ public class RabbitMQConsumer extends DefaultConsumer implements Suspendable {
@Override
protected void doResume() throws Exception {
- reconnect();
+ createConsumers();
+ startConsumers();
}
@Override
--
To stop receiving notification emails like this one, please contact
['"commits@camel.apache.org" <co...@camel.apache.org>'].