Remove rethrowable runtime exception during connection (#1137)

nats-io · May 13, 2024 · 70ee0a8 · 70ee0a8
1 parent 3c2903d
commit 70ee0a8
Showing 1 changed file with 1 addition and 7 deletions.
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);
         }
     }