From 3b450d9778899364353bb4b927e644344b7e621a Mon Sep 17 00:00:00 2001 From: PascalSchumacher Date: Mon, 24 Jun 2024 19:39:58 +0200 Subject: [PATCH] KahaDBStore: Fix typo in comment and remove duplicate semicolon --- .../java/org/apache/activemq/store/kahadb/KahaDBStore.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java index bde01d0404..50224a5dfa 100644 --- a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java +++ b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java @@ -101,7 +101,7 @@ public class KahaDBStore extends MessageDatabase implements PersistenceAdapter, PROPERTY_CANCELED_TASK_MOD_METRIC, "0"), 10); public static final String PROPERTY_ASYNC_EXECUTOR_MAX_THREADS = "org.apache.activemq.store.kahadb.ASYNC_EXECUTOR_MAX_THREADS"; private static final int asyncExecutorMaxThreads = Integer.parseInt(System.getProperty( - PROPERTY_ASYNC_EXECUTOR_MAX_THREADS, "1"), 10);; + PROPERTY_ASYNC_EXECUTOR_MAX_THREADS, "1"), 10); protected ExecutorService queueExecutor; protected ExecutorService topicExecutor; @@ -115,7 +115,7 @@ public class KahaDBStore extends MessageDatabase implements PersistenceAdapter, Semaphore globalTopicSemaphore; private boolean concurrentStoreAndDispatchQueues = true; // when true, message order may be compromised when cache is exhausted if store is out - // or order w.r.t cache + // of order w.r.t cache private boolean concurrentStoreAndDispatchTopics = false; private int maxAsyncJobs = MAX_ASYNC_JOBS; private final KahaDBTransactionStore transactionStore;