Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-06 10:09:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-2251 Using Callbacks to delete large messages from IO

Browse Source 
This closes #2549
This commit is contained in:
Clebert Suconic 2019-02-20 13:58:02 -05:00
parent 43c0868d72
commit 285848969f
1 changed files with 16 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/JournalStorageManager.java
View File

@ -39,6 +39,7 @@ import org.apache.activemq.artemis.api.core.Message;
import org.apache.activemq.artemis.api.core.Pair;
import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.core.config.Configuration;
import org.apache.activemq.artemis.core.io.IOCallback;
import org.apache.activemq.artemis.core.io.IOCriticalErrorListener;
import org.apache.activemq.artemis.core.io.SequentialFile;
import org.apache.activemq.artemis.core.io.SequentialFileFactory;
@ -506,11 +507,21 @@ public class JournalStorageManager extends AbstractJournalStorageManager {
};
if (executor == null) {
deleteAction.run();
} else {
executor.execute(deleteAction);
}
getContext(true).executeOnCompletion(new IOCallback() {
@Override
public void done() {
if (executor == null) {
deleteAction.run();
} else {
executor.execute(deleteAction);
}
}
@Override
public void onError(int errorCode, String errorMessage) {
}
});
}
@Override