From e7e9c9c9a0bfbf54829d17d0f5460e5dec20e560 Mon Sep 17 00:00:00 2001 From: Phillip Kruger Date: Tue, 6 Jun 2023 14:29:57 +1000 Subject: [PATCH] Fixed errors in log Signed-off-by: Phillip Kruger --- .../devui/deployment/menu/ContinuousTestingProcessor.java | 2 +- .../main/java/io/quarkus/devui/runtime/comms/JsonRpcRouter.java | 2 +- .../continuoustesting/ContinuousTestingJsonRPCService.java | 1 - 3 files changed, 2 insertions(+), 3 deletions(-) diff --git a/extensions/vertx-http/deployment/src/main/java/io/quarkus/devui/deployment/menu/ContinuousTestingProcessor.java b/extensions/vertx-http/deployment/src/main/java/io/quarkus/devui/deployment/menu/ContinuousTestingProcessor.java index 08787c427ab8f..ed41598d1cf3c 100644 --- a/extensions/vertx-http/deployment/src/main/java/io/quarkus/devui/deployment/menu/ContinuousTestingProcessor.java +++ b/extensions/vertx-http/deployment/src/main/java/io/quarkus/devui/deployment/menu/ContinuousTestingProcessor.java @@ -203,4 +203,4 @@ private void registerGetResultsMethod(LaunchModeBuildItem launchModeBuildItem) { private static final String NAMESPACE = "devui-continuous-testing"; private static final String DASH = "-"; -} \ No newline at end of file +} diff --git a/extensions/vertx-http/runtime/src/main/java/io/quarkus/devui/runtime/comms/JsonRpcRouter.java b/extensions/vertx-http/runtime/src/main/java/io/quarkus/devui/runtime/comms/JsonRpcRouter.java index dd29949c732ba..310437b29257a 100644 --- a/extensions/vertx-http/runtime/src/main/java/io/quarkus/devui/runtime/comms/JsonRpcRouter.java +++ b/extensions/vertx-http/runtime/src/main/java/io/quarkus/devui/runtime/comms/JsonRpcRouter.java @@ -197,7 +197,7 @@ private void route(JsonRpcRequest jsonRpcRequest, ServerWebSocket s) { } uni.subscribe() .with(item -> { - if (JsonRpcMessage.class.isAssignableFrom(item.getClass())) { + if (item != null && JsonRpcMessage.class.isAssignableFrom(item.getClass())) { JsonRpcMessage jsonRpcMessage = (JsonRpcMessage) item; codec.writeResponse(s, jsonRpcRequest.getId(), jsonRpcMessage.getResponse(), jsonRpcMessage.getMessageType()); diff --git a/extensions/vertx-http/runtime/src/main/java/io/quarkus/devui/runtime/continuoustesting/ContinuousTestingJsonRPCService.java b/extensions/vertx-http/runtime/src/main/java/io/quarkus/devui/runtime/continuoustesting/ContinuousTestingJsonRPCService.java index 6ca7ffa2a3532..7fc979b102c23 100644 --- a/extensions/vertx-http/runtime/src/main/java/io/quarkus/devui/runtime/continuoustesting/ContinuousTestingJsonRPCService.java +++ b/extensions/vertx-http/runtime/src/main/java/io/quarkus/devui/runtime/continuoustesting/ContinuousTestingJsonRPCService.java @@ -60,7 +60,6 @@ public String lastKnownResults() { return this.lastKnownResults; } - @NonBlocking public boolean start() { return invokeAction("start"); }