Shutdown!

datastax · May 14, 2024 · 618c2e7 · 618c2e7
1 parent 534343b
commit 618c2e7
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...ar-jms-filters/src/main/java/com/datastax/oss/pulsar/jms/selectors/JMSPublishFilters.java b/...ar-jms-filters/src/main/java/com/datastax/oss/pulsar/jms/selectors/JMSPublishFilters.java
@@ -592,7 +592,12 @@ public void close() {
     log.info("Broker is shutting down. Disabling JMSPublishFilters interceptor");
     closed.set(true);
     filter.close();
-    executor.shutdown();
+    if (executor != null) {
+      executor.shutdown();
+    }
+    if (drainAckQueueExecutor != null) {
+      drainAckQueueExecutor.shutdown();
+    }
   }
 
   @Override