ARTEMIS-3327 Removing unecessary block operation on journal append re…

…cord
apache · Jul 6, 2021 · 5c051e9 · 5c051e9
1 parent b5f772e
commit 5c051e9
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
@@ -935,7 +935,6 @@ public void appendAddRecord(final long id,
          throw ActiveMQJournalBundle.BUNDLE.recordLargerThanStoreMax(addRecordEncodeSize, maxRecordSize);
       }
 
-      final SimpleFuture<Boolean> result = newSyncAndCallbackResult(sync, callback);
       appendExecutor.execute(new Runnable() {
          @Override
          public void run() {
@@ -952,21 +951,16 @@ public void run() {
                                   ", usedFile = " +
                                   usedFile);
                }
-               result.set(true);
             } catch (ActiveMQShutdownException e) {
-               result.fail(e);
                logger.error("appendAddRecord:" + e, e);
             } catch (Throwable e) {
-               result.fail(e);
                setErrorCondition(callback, null, e);
                logger.error("appendAddRecord::"  + e, e);
             } finally {
                journalLock.readLock().unlock();
             }
          }
       });
-
-      result.get();
    }