Shutdown eventloop immediately

neo4j · Feb 23, 2024 · b91cc14 · b91cc14
1 parent fd9ef8c
commit b91cc14
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...r/src/main/java/org/neo4j/driver/internal/bolt/basicimpl/NettyBoltConnectionProvider.java b/...r/src/main/java/org/neo4j/driver/internal/bolt/basicimpl/NettyBoltConnectionProvider.java
@@ -28,6 +28,7 @@
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionException;
 import java.util.concurrent.CompletionStage;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.Consumer;
 import java.util.function.Function;
@@ -225,7 +226,9 @@ public CompletionStage<Void> close() {
         synchronized (this) {
             if (this.closeFuture == null) {
                 this.closeFuture = new CompletableFuture<>();
-                eventLoopGroup.shutdownGracefully().addListener(future -> this.closeFuture.complete(null));
+                eventLoopGroup
+                        .shutdownGracefully(0, 0, TimeUnit.MILLISECONDS)
+                        .addListener(future -> this.closeFuture.complete(null));
             }
             closeFuture = this.closeFuture;
         }