diff --git a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/AbstractSequentialFileFactory.java b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/AbstractSequentialFileFactory.java index 1d7a017085..5f191cfa4c 100644 --- a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/AbstractSequentialFileFactory.java +++ b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/AbstractSequentialFileFactory.java @@ -187,7 +187,7 @@ public abstract class AbstractSequentialFileFactory implements SequentialFileFac if (critialErrorListener != null) { critialErrorListener.onIOException(exception, message, file); } else { - logger.warn("Critical IO Error Called. No Critical IO Error Handler Registered"); + logger.warn("Critical IO Error Called. No Critical IO Error Handler Registered::" + message + " at file " + file, exception); } } diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/asyncio/AIOTestBase.java b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/asyncio/AIOTestBase.java index d5a7f5a3be..25eccbc7bc 100644 --- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/asyncio/AIOTestBase.java +++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/asyncio/AIOTestBase.java @@ -114,6 +114,7 @@ public abstract class AIOTestBase extends ActiveMQTestBase { @Override public void onError(final int errorCode, final String errorMessage) { + new Exception("Error called:: " + errorCode + " message::" + errorMessage).printStackTrace(); errorCalled++; if (outputList != null) { outputList.add(order); diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/asyncio/MultiThreadAsynchronousFileTest.java b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/asyncio/MultiThreadAsynchronousFileTest.java index 526663f97d..e9f51f9b2a 100644 --- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/asyncio/MultiThreadAsynchronousFileTest.java +++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/asyncio/MultiThreadAsynchronousFileTest.java @@ -210,8 +210,8 @@ public class MultiThreadAsynchronousFileTest extends AIOTestBase { addData(libaio, buffer, callback); if (sync) { waitForLatch(latchFinishThread); + assertEquals(0, callback.errorCalled); assertTrue(callback.doneCalled); - assertFalse(callback.errorCalled != 0); } } if (!sync) {