recreate thread pool

NucleoTeam · Sep 27, 2024 · a15c985 · a15c985
1 parent 0318603
commit a15c985
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/build.gradle b/build.gradle
@@ -7,7 +7,7 @@ plugins {
 }
 
 group = 'com.nucleodb'
-version = '1.18.15'
+version = '1.18.16'
 
 repositories {
     mavenCentral()

diff --git a/src/main/java/com/nucleodb/library/mqs/ConsumerHandler.java b/src/main/java/com/nucleodb/library/mqs/ConsumerHandler.java
@@ -55,6 +55,7 @@ public void readFromStart() throws InterruptedException {
     leftToRead.set(0);
     queueTasks.shutdownNow();
     queueTasks.awaitTermination(4, TimeUnit.SECONDS);
+    queueTasks = Executors.newFixedThreadPool(60);
   }
 
   @Override

diff --git a/src/main/java/com/nucleodb/library/mqs/kafka/KafkaConsumerHandler.java b/src/main/java/com/nucleodb/library/mqs/kafka/KafkaConsumerHandler.java
@@ -117,6 +117,7 @@ public void start(int queueHandlers) {
     public synchronized void readFromStart() throws InterruptedException {
         thread.shutdownNow();
         thread.awaitTermination(4, TimeUnit.SECONDS);
+        thread = Executors.newFixedThreadPool(1);
         boolean connectionType = this.getConnectionHandler() != null;
         boolean databaseType = this.getDatabase() != null;