This is an automated email from the ASF dual-hosted git repository. apupier pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit a600169eff2b9fd7b18f9b99b4a216bae1b4c255 Author: Aurélien Pupier <[email protected]> AuthorDate: Fri Oct 9 12:03:57 2026 +0200 CAMEL-25348: improve failure message on ACK timeout using AssertJ untilAsserted Co-authored-by: IBM Bob 2.2.1 Signed-off-by: Aurélien Pupier <[email protected]> --- components/camel-lumberjack/pom.xml | 5 +++++ .../java/org/apache/camel/component/lumberjack/LumberjackUtil.java | 6 +++++- 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/components/camel-lumberjack/pom.xml b/components/camel-lumberjack/pom.xml index 5e9bd7fba3e3..054b9811a0c1 100644 --- a/components/camel-lumberjack/pom.xml +++ b/components/camel-lumberjack/pom.xml @@ -64,6 +64,11 @@ <artifactId>camel-test-junit6</artifactId> <scope>test</scope> </dependency> + <dependency> + <groupId>org.assertj</groupId> + <artifactId>assertj-core</artifactId> + <scope>test</scope> + </dependency> </dependencies> </project> diff --git a/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackUtil.java b/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackUtil.java index 92314c7b6543..b1a7a74e5570 100644 --- a/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackUtil.java +++ b/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackUtil.java @@ -37,6 +37,7 @@ import io.netty.channel.socket.nio.NioSocketChannel; import io.netty.handler.ssl.SslHandler; import org.apache.camel.RuntimeCamelException; import org.apache.camel.support.jsse.SSLContextParameters; +import org.assertj.core.api.Assertions; import org.awaitility.Awaitility; import static io.netty.buffer.Unpooled.wrappedBuffer; @@ -97,7 +98,10 @@ final class LumberjackUtil { // send 5 frame windows, without pausing windows.stream().forEach(window -> channel.writeAndFlush(readSample(String.format("io/window%s.bin", window)))); if (waitForResult) { - Awaitility.await().atMost(30, TimeUnit.SECONDS).until(() -> windows.size() == responses.size()); + Awaitility.await().atMost(30, TimeUnit.SECONDS).untilAsserted( + () -> Assertions.assertThat(responses) + .as("Expected one ACK per window frame sent (%d), but received: %s", windows.size(), responses) + .hasSize(windows.size())); } channel.close().sync();
