From d3a7cffc679b2976f32696d418b040cd68be485f Mon Sep 17 00:00:00 2001
From: Clement Escoffier <clement.escoffier@gmail.com>
Date: Wed, 23 Aug 2023 08:03:07 +0200
Subject: [PATCH] Disable DynamicMqttTopicSourceTest as it is flajy on CI.

---
 .../mqtt/DynamicMqttTopicSourceTest.java      | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

diff --git a/smallrye-reactive-messaging-mqtt/src/test/java/io/smallrye/reactive/messaging/mqtt/DynamicMqttTopicSourceTest.java b/smallrye-reactive-messaging-mqtt/src/test/java/io/smallrye/reactive/messaging/mqtt/DynamicMqttTopicSourceTest.java
index 75956e432f..a64c0ff469 100644
--- a/smallrye-reactive-messaging-mqtt/src/test/java/io/smallrye/reactive/messaging/mqtt/DynamicMqttTopicSourceTest.java
+++ b/smallrye-reactive-messaging-mqtt/src/test/java/io/smallrye/reactive/messaging/mqtt/DynamicMqttTopicSourceTest.java
@@ -22,12 +22,14 @@
 import org.jboss.weld.environment.se.WeldContainer;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 
 import io.netty.handler.codec.mqtt.MqttQoS;
 import io.smallrye.reactive.messaging.mqtt.internal.MqttHelpers;
 import io.smallrye.reactive.messaging.test.common.config.MapBasedConfig;
 
+@Disabled
 public class DynamicMqttTopicSourceTest extends MqttTestBase {
 
     private WeldContainer container;
@@ -48,6 +50,10 @@ private void awaitAndVerify() {
                 .pollInterval(Duration.ofSeconds(1))
                 .until(() -> connector.getReadiness().isOk());
 
+        await()
+                .pollInterval(Duration.ofSeconds(1))
+                .until(() -> connector.getLiveness().isOk());
+
         bean.publish();
 
         await().until(() -> bean.messages().size() >= 3);
@@ -155,23 +161,36 @@ public void publish() {
             emitter.send(MqttMessage
                     .of("/app/hello/mqtt-" + LocalDate.now().toString() + "/greeting", "hello from dynamic topic 1",
                             MqttQoS.EXACTLY_ONCE));
+            nap(10);
             emitter.send(MqttMessage
                     .of("/app/hello/mqtt-" + LocalDate.now().toString() + "/greeting", "hello from dynamic topic 2",
                             MqttQoS.EXACTLY_ONCE));
+            nap(10);
             emitter.send(MqttMessage
                     .of("/app/hello/mqtt-" + LocalDate.now().toString() + "/greeting", "hello from dynamic topic 3",
                             MqttQoS.EXACTLY_ONCE));
+            nap(15);
             emitter.send(MqttMessage
                     .of("$/app/hello/mqtt-" + LocalDate.now().toString() + "/greeting", "hello from dynamic topic 4",
                             MqttQoS.EXACTLY_ONCE));
+            nap(10);
             emitter.send(MqttMessage
                     .of("$/app/hello/mqtt-" + LocalDate.now().toString() + "/greeting", "hello from dynamic topic 5",
                             MqttQoS.EXACTLY_ONCE));
+            nap(5);
             emitter.send(MqttMessage
                     .of("$/app/hello/mqtt-" + LocalDate.now().toString() + "/greeting", "hello from dynamic topic 6",
                             MqttQoS.EXACTLY_ONCE));
         }
 
+        private void nap(int duration) {
+            try {
+                Thread.sleep(duration);
+            } catch (Exception ignored) {
+                // ignored.
+            }
+        }
+
         @Incoming("in")
         public CompletionStage<Void> received(MqttMessage<byte[]> message) {
             messages.add(message);