NO-JIRA skeleton test for MQTT

apache · Dec 5, 2023 · afe0e88 · afe0e88
1 parent c3963b4
commit afe0e88
Showing 1 changed file with 22 additions and 0 deletions.
diff --git a/...on-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt5/MQTT5Test.java b/...on-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt5/MQTT5Test.java
@@ -59,6 +59,28 @@ public MQTT5Test(String protocol) {
       super(protocol);
    }
 
+   @Test(timeout = DEFAULT_TIMEOUT)
+   public void testSimpleSendReceive() throws Exception {
+      String topic = RandomUtil.randomString();
+
+      CountDownLatch latch = new CountDownLatch(1);
+      MqttClient subscriber = createPahoClient("subscriber");
+      subscriber.connect();
+      subscriber.setCallback(new DefaultMqttCallback() {
+         @Override
+         public void messageArrived(String topic, MqttMessage message) throws Exception {
+            log.info("Message received from {}", topic);
+            latch.countDown();
+         }
+      });
+      subscriber.subscribe(topic, AT_LEAST_ONCE);
+
+      MqttClient producer = createPahoClient("producer");
+      producer.connect();
+      producer.publish(topic, "myMessage".getBytes(StandardCharsets.UTF_8), 1, false);
+      assertTrue(latch.await(500, TimeUnit.MILLISECONDS));
+   }
+
    /*
     * Ensure that the broker adds a timestamp on the message when sending via MQTT
     */