Skip to content

Commit 8b4a26b

Browse files
committed
Fix test flake
Fix the followin flake: ``` [ERROR] com.rabbitmq.mqtt.test.MqttTest.sessionRedelivery(TestInfo) -- Time elapsed: 0.959 s <<< FAILURE! org.opentest4j.AssertionFailedError: Expecting value to be false but was true at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at com.rabbitmq.mqtt.test.MqttTest.sessionRedelivery(MqttTest.java:523) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at java.base/java.util.ArrayList.forEach(ArrayList.java:1541) at java.base/java.util.ArrayList.forEach(ArrayList.java:1541) [ERROR] Failures: [ERROR] MqttTest.sessionRedelivery:523 Expecting value to be false but was true ```
1 parent 81cbc0a commit 8b4a26b

File tree

1 file changed

+1
-0
lines changed
  • deps/rabbitmq_mqtt/test/java_SUITE_data/src/test/java/com/rabbitmq/mqtt/test

1 file changed

+1
-0
lines changed

deps/rabbitmq_mqtt/test/java_SUITE_data/src/test/java/com/rabbitmq/mqtt/test/MqttTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -520,6 +520,7 @@ public void sessionRedelivery(TestInfo info) throws MqttException, InterruptedEx
520520
// Message has been delivered but connection has failed.
521521
waitAtMost(() -> receivedMessagesSize() == 1);
522522
assertThat(firstMessage().getPayload()).isEqualTo(payload);
523+
Thread.sleep(100);
523524
assertThat(client.isConnected()).isFalse();
524525

525526
receivedMessages.clear();

0 commit comments

Comments
 (0)