[camel] branch master updated: Fixed test

[davsclaus]

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 f260486  Fixed test
f260486 is described below

commit f2604862cfc6d1e912aca44c7cd21242ab427c68
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sat Feb 27 11:27:46 2021 +0100

    Fixed test
---
 .../component/rabbitmq/integration/RabbitMQInOutIntTest.java     | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/integration/RabbitMQInOutIntTest.java
 
b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/integration/RabbitMQInOutIntTest.java
index 855378d..3057a61 100644
--- 
a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/integration/RabbitMQInOutIntTest.java
+++ 
b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/integration/RabbitMQInOutIntTest.java
@@ -277,7 +277,8 @@ public class RabbitMQInOutIntTest extends 
AbstractRabbitMQIntTest {
     }
 
     @Test
-    public void messageAckOnExceptionWhereNoAutoAckTest() throws Exception {
+    // should run last
+    public void zRunLstMessageAckOnExceptionWhereNoAutoAckTest() throws 
Exception {
         Map<String, Object> headers = new HashMap<>();
         headers.put(RabbitMQConstants.EXCHANGE_NAME, EXCHANGE_NO_ACK);
         headers.put(RabbitMQConstants.ROUTING_KEY, ROUTING_KEY);
@@ -300,6 +301,12 @@ public class RabbitMQInOutIntTest extends 
AbstractRabbitMQIntTest {
 
         context.stop(); // On restarting the camel context, if the message was
                        // not acknowledged the message would be reprocessed
+
+        // registry is cleaned on stop so we need to re-register
+        Map<String, Object> args = new HashMap<>();
+        args.put(RabbitMQConstants.RABBITMQ_QUEUE_TTL_KEY, 60000);
+        context.getRegistry().bind("args", args);
+
         context.start();
 
         resultEndpoint.assertIsSatisfied();