Fix nullpointer on null code ws-next

quarkusio · Nov 14, 2024 · 1069847 · 1069847
1 parent 7fa4088
commit 1069847
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...runtime/src/main/java/io/quarkus/websockets/next/runtime/BasicWebSocketConnectorImpl.java b/...runtime/src/main/java/io/quarkus/websockets/next/runtime/BasicWebSocketConnectorImpl.java
@@ -239,7 +239,11 @@ public void handle(Void event) {
                         trafficLogger.connectionClosed(connection);
                     }
                     if (closeHandler != null) {
-                        doExecute(connection, new CloseReason(ws.closeStatusCode(), ws.closeReason()), closeHandler);
+                        CloseReason reason = CloseReason.INTERNAL_SERVER_ERROR;
+                        if (ws.closeStatusCode() != null) {
+                            reason = new CloseReason(ws.closeStatusCode(), ws.closeReason());
+                        }
+                        doExecute(connection, reason, closeHandler);
                     }
                     connectionManager.remove(BasicWebSocketConnectorImpl.class.getName(), connection);
                     client.get().close();