Fix formatting

This commit is contained in:
Artem Bilan
2024-11-20 09:49:17 -05:00
parent 8b4d3b7b54
commit 24299bed59

View File

@@ -45,7 +45,8 @@ public class BatchInsertTimeoutTests extends JdbcConsumerApplicationTests {
final Message<Payload> message = MessageBuilder.withPayload(sent).build();
jdbcConsumer.accept(message);
}
Awaitility.await().atMost(Duration.ofSeconds(30))
Awaitility.await()
.atMost(Duration.ofSeconds(30))
.until(() -> jdbcOperations.queryForObject("select count(*) from messages", Integer.class),
(value) -> value == numberOfInserts);
}