Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #1991

This commit is contained in:
Clebert Suconic 2018-04-04 17:07:17 -04:00
parent 6ec375bdbe 65db317176
commit 2feacd5d5d
3 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/AbstractSequentialFileFactory.java
View File

@ -187,7 +187,7 @@ public abstract class AbstractSequentialFileFactory implements SequentialFileFac
if (critialErrorListener != null) { if (critialErrorListener != null) {
critialErrorListener.onIOException(exception, message, file); critialErrorListener.onIOException(exception, message, file);
} else { } 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);
} }
} }

1
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/asyncio/AIOTestBase.java
View File

@ -114,6 +114,7 @@ public abstract class AIOTestBase extends ActiveMQTestBase {
@Override @Override
public void onError(final int errorCode, final String errorMessage) { public void onError(final int errorCode, final String errorMessage) {
new Exception("Error called:: " + errorCode + " message::" + errorMessage).printStackTrace();
errorCalled++; errorCalled++;
if (outputList != null) { if (outputList != null) {
outputList.add(order); outputList.add(order);

2
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/asyncio/MultiThreadAsynchronousFileTest.java
View File

@ -210,8 +210,8 @@ public class MultiThreadAsynchronousFileTest extends AIOTestBase {
addData(libaio, buffer, callback); addData(libaio, buffer, callback);
if (sync) { if (sync) {
waitForLatch(latchFinishThread); waitForLatch(latchFinishThread);
assertEquals(0, callback.errorCalled);
assertTrue(callback.doneCalled); assertTrue(callback.doneCalled);
assertFalse(callback.errorCalled != 0);
} }
} }
if (!sync) { if (!sync) {