We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0b75987 commit b73ba4eCopy full SHA for b73ba4e
1 file changed
src/test/java/software/amazon/awssdk/crt/test/Mqtt5ClientTest.java
@@ -2069,6 +2069,8 @@ private void doOp_SharedSubscriptionTest() {
2069
subscriberOneClient.subscribe(subscribePacketBuilder.build()).get(OPERATION_TIMEOUT_TIME, TimeUnit.SECONDS);
2070
subscriberTwoClient.subscribe(subscribePacketBuilder.build()).get(OPERATION_TIMEOUT_TIME, TimeUnit.SECONDS);
2071
2072
+ Thread.sleep(4000);
2073
+
2074
for (int i = 0; i < messageCount; ++i) {
2075
publishPacketBuilder.withPayload(String.valueOf(i).getBytes());
2076
publisherClient.publish(publishPacketBuilder.build()).get(OPERATION_TIMEOUT_TIME, TimeUnit.SECONDS);
0 commit comments