Skip to content

Commit 37fd5e8

Browse files
author
Ian Craggs
committed
Increase maximum timeout waiting for message in test, just in case
1 parent 1eb55d7 commit 37fd5e8

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

  • org.eclipse.paho.client.mqttv3.test/src/test/java/org/eclipse/paho/client/mqttv3/test

org.eclipse.paho.client.mqttv3.test/src/test/java/org/eclipse/paho/client/mqttv3/test/ModelTestCase.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -633,7 +633,8 @@ public void deliveryComplete(IMqttDeliveryToken token) {
633633
public void waitForMessage(String topic, MqttMessage message, boolean expectRetained)
634634
throws Exception {
635635
synchronized (lock) {
636-
if (messages.size() == 0) {
636+
int count = 0;
637+
while (messages.size() == 0 && ++count < 10) {
637638
lock.wait(1000);
638639
}
639640
if (messages.size() == 0) {

0 commit comments

Comments
 (0)