diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/LargeMessageTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/LargeMessageTest.java index 79c767434f..7d4df6136a 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/LargeMessageTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/LargeMessageTest.java @@ -297,6 +297,7 @@ public class LargeMessageTest extends LargeMessageTestBase { assertEquals("position = " + i, getSamplebyte(i), message.getBodyBuffer().readByte()); } message.acknowledge(); + session.commit(); validateNoFilesOnLargeDir(); }