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

ARTEMIS-3273 Moving verification of directory

This commit is contained in:
Clebert Suconic 2021-05-03 09:10:48 -04:00 committed by clebertsuconic
parent a34d9aad6b
commit fe361d3fae
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/RecoverMessages.java
View File

@ -57,11 +57,7 @@ public class RecoverMessages extends DBOption {
Configuration configuration = getParameterConfiguration();
File journalOutput = new File(outputJournal);
journalOutput.mkdirs();
if (!journalOutput.isDirectory()) {
throw new IllegalStateException(outputJournal + " is not a directory");
}
try {
if (configuration.isJDBC()) {
@ -79,7 +75,15 @@ public class RecoverMessages extends DBOption {
File journal = configuration.getJournalLocation();
journalOutput.mkdirs();
if (!journalOutput.exists()) {
if (!journalOutput.mkdirs()) {
throw new IllegalStateException("It was not possible to create " + journalOutput);
}
}
if (journalOutput.exists() && !journalOutput.isDirectory()) {
throw new IllegalStateException(journalOutput + " is not a directory");
}
SequentialFileFactory outputFF = new NIOSequentialFileFactory(journalOutput, null, 1);
outputFF.setDatasync(false);