Remove rethrowable runtime exception during connection (#1137)

ajax-surovskyi-y · web-flow · commit 70ee0a83c9c8 · 2024-05-13T12:19:21.000-04:00
diff --git a/src/main/java/io/nats/client/impl/NatsConnection.java b/src/main/java/io/nats/client/impl/NatsConnection.java
@@ -880,13 +880,7 @@ void closeSocketImpl() {
     void cleanUpPongQueue() {
         Future<Boolean> b;
         while ((b = pongQueue.poll()) != null) {
-            try {
-                b.cancel(true);
-            } catch (CancellationException e) {
-                if (!b.isDone() && !b.isCancelled()) {
-                    processException(e);
-                }
-            }
+            b.cancel(true);
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -880,13 +880,7 @@ void closeSocketImpl() {`
`880`	`880`	`void cleanUpPongQueue() {`
`881`	`881`	`Future<Boolean> b;`
`882`	`882`	`while ((b = pongQueue.poll()) != null) {`
`883`		`- try {`
`884`		`- b.cancel(true);`
`885`		`- } catch (CancellationException e) {`
`886`		`- if (!b.isDone() && !b.isCancelled()) {`
`887`		`- processException(e);`
`888`		`- }`
`889`		`- }`
	`883`	`+ b.cancel(true);`
`890`	`884`	`}`
`891`	`885`	`}`
`892`	`886`