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:23:05 UTC

[camel] branch master 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 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 03900cb  CAMEL-12129: fix broken integration test from CAMEL-12111
03900cb is described below

commit 03900cb2c9c6c6ceb6900e95455ce663b0a1c509
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>'].