NO-JIRA sanity test of mqtt shared sub publish with fqqn

This commit is contained in:
Gary Tully 2024-09-03 15:29:47 +01:00 committed by Justin Bertram
parent 7605bd673f
commit 57adcd3286
1 changed files with 5 additions and 0 deletions

View File

@ -524,6 +524,11 @@ public class MQTT5Test extends MQTT5TestSupport {
producer.publish(TOPIC, new byte[0], 1, false);
assertTrue(ackLatch.await(2, TimeUnit.SECONDS));
// sanity send using fqqn as we can know the name of a shared sub
ackLatch.countUp();
producer.publish(TOPIC + "::" + SUB_NAME + "/" + TOPIC, new byte[0], 1, false);
assertTrue(ackLatch.await(2, TimeUnit.SECONDS));
producer.disconnect();
producer.close();
consumer1.disconnect();