NO-JIRA removing runDirectJournalBlast

artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java

@@ -968,10 +968,6 @@ public class JDBCJournalImpl extends AbstractJDBCDriver implements Journal {
       return USER_VERSION;
    }
 
-   @Override
-   public void runDirectJournalBlast() throws Exception {
-   }
-
    @Override
    public Map<Long, JournalFile> createFilesForBackupSync(long[] fileIds) throws Exception {
       return null;

artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/Journal.java

@@ -257,8 +257,6 @@ public interface Journal extends ActiveMQComponent {
 
    int getUserVersion();
 
-   void runDirectJournalBlast() throws Exception;
-
    /**
     * Reserves journal file IDs, creates the necessary files for synchronization, and places
     * references to these (reserved for sync) files in the map.

artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/FileWrapperJournal.java

@@ -322,11 +322,6 @@ public final class FileWrapperJournal extends JournalBase {
       throw new UnsupportedOperationException();
    }
 
-   @Override
-   public void runDirectJournalBlast() throws Exception {
-      throw new UnsupportedOperationException();
-   }
-
    @Override
    public JournalLoadInformation loadSyncOnly(JournalState state) throws Exception {
       throw new UnsupportedOperationException();

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

@@ -401,65 +401,6 @@ public class JournalImpl extends JournalBase implements TestableJournal, Journal
       }
    }
 
-   @Override
-   public void runDirectJournalBlast() throws Exception {
-      final int numIts = 100000000;
-
-      ActiveMQJournalLogger.LOGGER.runningJournalBlast(numIts);
-
-      final CountDownLatch latch = new CountDownLatch(numIts * 2);
-
-      class MyAIOCallback implements IOCompletion {
-
-         @Override
-         public void done() {
-            latch.countDown();
-         }
-
-         @Override
-         public void onError(final int errorCode, final String errorMessage) {
-
-         }
-
-         @Override
-         public void storeLineUp() {
-         }
-      }
-
-      final MyAIOCallback task = new MyAIOCallback();
-
-      final int recordSize = 1024;
-
-      final byte[] bytes = new byte[recordSize];
-
-      class MyRecord implements EncodingSupport {
-
-         @Override
-         public void decode(final ActiveMQBuffer buffer) {
-         }
-
-         @Override
-         public void encode(final ActiveMQBuffer buffer) {
-            buffer.writeBytes(bytes);
-         }
-
-         @Override
-         public int getEncodeSize() {
-            return recordSize;
-         }
-
-      }
-
-      MyRecord record = new MyRecord();
-
-      for (int i = 0; i < numIts; i++) {
-         appendAddRecord(i, (byte) 1, record, true, task);
-         appendDeleteRecord(i, true, task);
-      }
-
-      latch.await();
-   }
-
    @Override
    public ConcurrentLongHashMap<JournalRecord> getRecords() {
       return records;

artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicatedJournal.java

@@ -566,11 +566,6 @@ public class ReplicatedJournal implements Journal {
       return localJournal.getNumberOfRecords();
    }
 
-   @Override
-   public void runDirectJournalBlast() throws Exception {
-      localJournal.runDirectJournalBlast();
-   }
-
    @Override
    public int getUserVersion() {
       return localJournal.getUserVersion();

artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/PostOfficeJournalLoader.java

@@ -290,10 +290,6 @@ public class PostOfficeJournalLoader implements JournalLoader {
             queue.resume();
          }
       }
-
-      if (System.getProperty("org.apache.activemq.opt.directblast") != null) {
-         messageJournal.runDirectJournalBlast();
-      }
    }
 
    @Override

tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/ReplicationTest.java

@@ -969,10 +969,6 @@ public final class ReplicationTest extends ActiveMQTestBase {
       public void sync(final IOCompletion callback) {
       }
 
-      @Override
-      public void runDirectJournalBlast() throws Exception {
-      }
-
       @Override
       public int getUserVersion() {
          return 0;