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 #3644

This commit is contained in:
Justin Bertram 2021-07-06 14:59:33 -05:00
parent b5f772e9e5 5c051e9832
commit d800957bfb
1 changed files with 0 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
View File

@ -935,7 +935,6 @@ public class JournalImpl extends JournalBase implements TestableJournal, Journal
throw ActiveMQJournalBundle.BUNDLE.recordLargerThanStoreMax(addRecordEncodeSize, maxRecordSize); throw ActiveMQJournalBundle.BUNDLE.recordLargerThanStoreMax(addRecordEncodeSize, maxRecordSize);
} }
final SimpleFuture<Boolean> result = newSyncAndCallbackResult(sync, callback);
appendExecutor.execute(new Runnable() { appendExecutor.execute(new Runnable() {
@Override @Override
public void run() { public void run() {
@ -952,12 +951,9 @@ public class JournalImpl extends JournalBase implements TestableJournal, Journal
", usedFile = " + ", usedFile = " +
usedFile); usedFile);
} }
result.set(true);
} catch (ActiveMQShutdownException e) { } catch (ActiveMQShutdownException e) {
result.fail(e);
logger.error("appendAddRecord:" + e, e); logger.error("appendAddRecord:" + e, e);
} catch (Throwable e) { } catch (Throwable e) {
result.fail(e);
setErrorCondition(callback, null, e); setErrorCondition(callback, null, e);
logger.error("appendAddRecord::" + e, e); logger.error("appendAddRecord::" + e, e);
} finally { } finally {
@ -965,8 +961,6 @@ public class JournalImpl extends JournalBase implements TestableJournal, Journal
} }
} }
}); });
result.get();
} }