SingleWriterService > Handle all exceptions that can be thrown durin…

…g the task execution. This allows all futures to finish and issues being visible.
hivemq · Dec 12, 2023 · d8d67b6 · d8d67b6
1 parent e56af0f
commit d8d67b6
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/src/main/java/com/hivemq/persistence/InMemoryProducerQueues.java b/src/main/java/com/hivemq/persistence/InMemoryProducerQueues.java
@@ -150,7 +150,7 @@ public InMemoryProducerQueues(final int persistenceBucketCount, final int amount
                 } else {
                     successCallback.afterTask(result);
                 }
-            } catch (final Exception e) {
+            } catch (final Throwable e) {
                 if (resultFuture != null) {
                     resultFuture.setException(e);
                 } else {

diff --git a/src/main/java/com/hivemq/persistence/ProducerQueuesImpl.java b/src/main/java/com/hivemq/persistence/ProducerQueuesImpl.java
@@ -230,7 +230,7 @@ public void execute(final @NotNull SplittableRandom random) {
                                         .afterTask(result));
                             }
                         }
-                    } catch (final Exception e) {
+                    } catch (final Throwable e) {
                         if (taskWithFuture.getFuture() != null) {
                             taskWithFuture.getFuture().setException(e);
                         } else {

diff --git a/src/main/java/com/hivemq/persistence/SingleWriterService.java b/src/main/java/com/hivemq/persistence/SingleWriterService.java
@@ -46,6 +46,6 @@ interface SuccessCallback<R> {
     }
 
     interface FailedCallback {
-        void afterTask(@NotNull Exception exception);
+        void afterTask(@NotNull Throwable exception);
     }
 }