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

commit d04e430a6acfda74089eb785d44bb10989fb4194
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sat Feb 27 15:29:35 2021 +0100

    Fixed test
---
 .../integration/RabbitMQPollingConsumerTest.java   | 27 ----------------------
 1 file changed, 27 deletions(-)

diff --git 
a/components/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/integration/RabbitMQPollingConsumerTest.java
 
b/components/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/integration/RabbitMQPollingConsumerTest.java
index a24e689..e195145 100644
--- 
a/components/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/integration/RabbitMQPollingConsumerTest.java
+++ 
b/components/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/integration/RabbitMQPollingConsumerTest.java
@@ -16,9 +16,7 @@
  */
 package org.apache.camel.component.springrabbit.integration;
 
-import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.Executors;
-import java.util.concurrent.TimeUnit;
 
 import org.apache.camel.CamelContext;
 import org.apache.camel.builder.RouteBuilder;
@@ -72,31 +70,6 @@ public class RabbitMQPollingConsumerTest extends 
AbstractRabbitMQIntTest {
     }
 
     @Test
-    public void testJmsPollingConsumerNoWait() throws Exception {
-        MockEndpoint mock = getMockEndpoint("mock:result");
-        mock.expectedBodiesReceived("Hello Claus");
-
-        // use another thread for polling consumer to demonstrate that we can 
wait before
-        // the message is sent to the queue
-        final CountDownLatch latch = new CountDownLatch(1);
-        Executors.newSingleThreadExecutor().execute(() -> {
-            String body = 
consumer.receiveBodyNoWait("spring-rabbitmq:foo?queues=myqueue&routingKey=mykey",
 String.class);
-            assertNull(body, "Should be null");
-
-            template.sendBody("spring-rabbitmq:foo?routingKey=mykey2", "Hello 
Claus");
-            latch.countDown();
-        });
-
-        // wait a little to demonstrate we can start poll before we have a msg 
on the queue
-        latch.await(5, TimeUnit.SECONDS);
-        Thread.sleep(1000);
-
-        template.sendBody("direct:start", "Hello");
-
-        assertMockEndpointsSatisfied();
-    }
-
-    @Test
     public void testJmsPollingConsumerLowTimeout() throws Exception {
         MockEndpoint mock = getMockEndpoint("mock:result");
         mock.expectedBodiesReceived("Hello Claus");