Added try-catch around user-defined code

alex268 · alex268 · commit 1db8bdafa293 · 2025-05-20T13:39:46.000+01:00
diff --git a/topic/src/main/java/tech/ydb/topic/impl/GrpcStreamRetrier.java b/topic/src/main/java/tech/ydb/topic/impl/GrpcStreamRetrier.java
@@ -137,7 +137,11 @@ protected void onSessionClosed(Status status, Throwable th) {
         }
 
         if (errorsHandler != null) {
-            errorsHandler.accept(status, th);
+            try {
+                errorsHandler.accept(status, th);
+            } catch (Exception ex) {
+                getLogger().error("[{}] error handler throws exception", id, ex);
+            }
         }
 
         if (!isStopped.get()) {

Original file line number	Diff line number	Diff line change
`@@ -137,7 +137,11 @@ protected void onSessionClosed(Status status, Throwable th) {`
`137`	`137`	`}`
`138`	`138`
`139`	`139`	`if (errorsHandler != null) {`
`140`		`- errorsHandler.accept(status, th);`
	`140`	`+ try {`
	`141`	`+ errorsHandler.accept(status, th);`
	`142`	`+ } catch (Exception ex) {`
	`143`	`+ getLogger().error("[{}] error handler throws exception", id, ex);`
	`144`	`+ }`
`141`	`145`	`}`
`142`	`146`
`143`	`147`	`if (!isStopped.get()) {`