[karaf-decanter] branch master updated: Improve MqttCollectorTest

[jbonofre]

This is an automated email from the ASF dual-hosted git repository.

jbonofre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/karaf-decanter.git


The following commit(s) were added to refs/heads/master by this push:
     new 260dfac  Improve MqttCollectorTest
260dfac is described below

commit 260dfac6525516f23c5dcfdabff004bbb053a002
Author: jbonofre <jbono...@apache.org>
AuthorDate: Mon Nov 30 14:32:44 2020 +0100

    Improve MqttCollectorTest
---
 .../org/apache/karaf/decanter/collector/mqtt/MqttCollectorTest.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/collector/mqtt/src/test/java/org/apache/karaf/decanter/collector/mqtt/MqttCollectorTest.java
 
b/collector/mqtt/src/test/java/org/apache/karaf/decanter/collector/mqtt/MqttCollectorTest.java
index 23e0d20..373879b 100644
--- 
a/collector/mqtt/src/test/java/org/apache/karaf/decanter/collector/mqtt/MqttCollectorTest.java
+++ 
b/collector/mqtt/src/test/java/org/apache/karaf/decanter/collector/mqtt/MqttCollectorTest.java
@@ -52,7 +52,7 @@ public class MqttCollectorTest {
         broker.start();
     }
 
-    @Test
+    @Test(timeout = 120000)
     public void sendDecanterMessage() throws Exception {
         DispatcherMock dispatcherMock = new DispatcherMock();
         ComponentContext componentContext = new ComponentContextMock();
@@ -72,7 +72,9 @@ public class MqttCollectorTest {
         mqttClient.publish("decanter", message);
         mqttClient.disconnect();
 
-        Thread.sleep(200L);
+        while (dispatcherMock.getPostEvents().size() != 1) {
+            Thread.sleep(100);
+        }
 
         Assert.assertEquals(1, dispatcherMock.getPostEvents().size());
         Event event = dispatcherMock.getPostEvents().get(0);