+
+ Awaitility
+ .await()
+ .atMost(Duration.ofSeconds(30))
+ .until(() ->
+ {
+ for (int i = 0; i < testWriters.length; i++)
+ {
+ TestWriter testWriter = testWriters[i];
+ int sentTotal = testWriter.getNumSentMessages();
+ if (sentTotal == numSentMessages[i])
+ {
+ log.info(
+ "No progress for {}: sent-before={}, sent-total={}",
+ testWriter,
+ numSentMessages[i],
+ sentTotal);
+ return false;
+ }
+ }
+
+ return true;
+ });