Catch errors in Dispatchers and log (#1200)

MauriceVanVeen · web-flow · commit 9ca3a9293f46 · 2024-08-12T15:48:59.000-04:00
Signed-off-by: Maurice van Veen &lt;github@mauricevanveen.com&gt;
diff --git a/src/main/java/io/nats/client/impl/NatsDispatcher.java b/src/main/java/io/nats/client/impl/NatsDispatcher.java
@@ -106,6 +106,8 @@ public void run() {
                                 handler.onMessage(msg);
                             } catch (Exception exp) {
                                 connection.processException(exp);
+                            } catch (Error err) {
+                                connection.processException(new Exception(err));
                             }
 
                             if (sub.reachedUnsubLimit()) {
diff --git a/src/main/java/io/nats/client/impl/NatsDispatcherWithExecutor.java b/src/main/java/io/nats/client/impl/NatsDispatcherWithExecutor.java
@@ -48,6 +48,8 @@ public void run() {
                                     finalHandler.onMessage(msg);
                                 } catch (Exception exp) {
                                     connection.processException(exp);
+                                } catch (Error err) {
+                                    connection.processException(new Exception(err));
                                 }
 
                                 if (sub.reachedUnsubLimit()) {

Original file line number	Diff line number	Diff line change
`@@ -106,6 +106,8 @@ public void run() {`
`106`	`106`	`handler.onMessage(msg);`
`107`	`107`	`} catch (Exception exp) {`
`108`	`108`	`connection.processException(exp);`
	`109`	`+ } catch (Error err) {`
	`110`	`+ connection.processException(new Exception(err));`
`109`	`111`	`}`
`110`	`112`
`111`	`113`	`if (sub.reachedUnsubLimit()) {`
Original file line number	Diff line number	Diff line change
`@@ -48,6 +48,8 @@ public void run() {`
`48`	`48`	`finalHandler.onMessage(msg);`
`49`	`49`	`} catch (Exception exp) {`
`50`	`50`	`connection.processException(exp);`
	`51`	`+ } catch (Error err) {`
	`52`	`+ connection.processException(new Exception(err));`
`51`	`53`	`}`
`52`	`54`
`53`	`55`	`if (sub.reachedUnsubLimit()) {`