diff --git a/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/McpMessageHandler.java b/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/McpMessageHandler.java index 3ea56fa..f0bac45 100644 --- a/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/McpMessageHandler.java +++ b/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/McpMessageHandler.java @@ -82,7 +82,7 @@ private void initializing(JsonObject message, Responder responder, McpConnection String method = message.getString("method"); if (NOTIFICATIONS_INITIALIZED.equals(method)) { if (connection.setInitialized()) { - LOG.infof("Client successfully initialized [%s]", connection.id()); + LOG.debugf("Client successfully initialized [%s]", connection.id()); } } else if (PING.equals(method)) { ping(message, responder); @@ -153,13 +153,13 @@ private void complete(JsonObject message, Responder responder, McpConnection con private void ping(JsonObject message, Responder responder) { // https://spec.modelcontextprotocol.io/specification/basic/utilities/ping/ Object id = message.getValue("id"); - LOG.infof("Ping [id: %s]", id); + LOG.debugf("Ping [id: %s]", id); responder.sendResult(id, new JsonObject()); } private void close(JsonObject message, Responder responder, McpConnection connection) { if (connectionManager.remove(connection.id())) { - LOG.infof("Connection %s closed", connection.id()); + LOG.debugf("Connection %s closed", connection.id()); } else { responder.sendError(message.getValue("id"), JsonRPC.INTERNAL_ERROR, "Unable to obtain the connection to be closed:" + connection.id()); diff --git a/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/PromptCompletionMessageHandler.java b/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/PromptCompletionMessageHandler.java index 399500b..148ce14 100644 --- a/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/PromptCompletionMessageHandler.java +++ b/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/PromptCompletionMessageHandler.java @@ -25,7 +25,7 @@ void promptComplete(Object id, JsonObject ref, JsonObject argument, Responder re String promptName = ref.getString("name"); String argumentName = argument.getString("name"); - LOG.infof("Complete prompt %s for argument %s [id: %s]", promptName, argumentName, id); + LOG.debugf("Complete prompt %s for argument %s [id: %s]", promptName, argumentName, id); String key = promptName + "_" + argumentName; diff --git a/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/PromptMessageHandler.java b/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/PromptMessageHandler.java index 341587e..39a2a2a 100644 --- a/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/PromptMessageHandler.java +++ b/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/PromptMessageHandler.java @@ -22,7 +22,7 @@ class PromptMessageHandler { void promptsList(JsonObject message, Responder responder) { Object id = message.getValue("id"); - LOG.infof("List prompts [id: %s]", id); + LOG.debugf("List prompts [id: %s]", id); JsonArray prompts = new JsonArray(); for (FeatureMetadata resource : promptManager.list()) { prompts.add(resource.asJson()); @@ -34,7 +34,7 @@ void promptsGet(JsonObject message, Responder responder, McpConnection connectio Object id = message.getValue("id"); JsonObject params = message.getJsonObject("params"); String promptName = params.getString("name"); - LOG.infof("Get prompt %s [id: %s]", promptName, id); + LOG.debugf("Get prompt %s [id: %s]", promptName, id); ArgumentProviders argProviders = new ArgumentProviders(params.getJsonObject("arguments").getMap(), connection, id); diff --git a/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/ResourceMessageHandler.java b/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/ResourceMessageHandler.java index ec05f36..38de08e 100644 --- a/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/ResourceMessageHandler.java +++ b/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/ResourceMessageHandler.java @@ -24,7 +24,7 @@ class ResourceMessageHandler { void resourcesList(JsonObject message, Responder responder) { Object id = message.getValue("id"); - LOG.infof("List resources [id: %s]", id); + LOG.debugf("List resources [id: %s]", id); JsonArray resources = new JsonArray(); for (FeatureMetadata resource : resourceManager.list()) { resources.add(resource.asJson()); @@ -40,7 +40,7 @@ void resourcesRead(JsonObject message, Responder responder, McpConnection connec responder.sendError(id, JsonRPC.INVALID_PARAMS, "Resource URI not defined"); return; } - LOG.infof("Read resource %s [id: %s]", resourceUri, id); + LOG.debugf("Read resource %s [id: %s]", resourceUri, id); ArgumentProviders argProviders = new ArgumentProviders(Map.of("uri", resourceUri), connection, id); diff --git a/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/ResourceTemplateMessageHandler.java b/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/ResourceTemplateMessageHandler.java index 206f673..26fe28a 100644 --- a/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/ResourceTemplateMessageHandler.java +++ b/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/ResourceTemplateMessageHandler.java @@ -18,7 +18,7 @@ class ResourceTemplateMessageHandler { void resourceTemplatesList(JsonObject message, Responder responder) { Object id = message.getValue("id"); - LOG.infof("List resource templates [id: %s]", id); + LOG.debugf("List resource templates [id: %s]", id); JsonArray resources = new JsonArray(); for (FeatureMetadata resource : manager.list()) { resources.add(resource.asJson()); diff --git a/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/ToolMessageHandler.java b/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/ToolMessageHandler.java index e9929bf..8bee7f2 100644 --- a/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/ToolMessageHandler.java +++ b/core/runtime/src/main/java/io/quarkiverse/mcp/server/runtime/ToolMessageHandler.java @@ -35,7 +35,7 @@ class ToolMessageHandler { void toolsList(JsonObject message, Responder responder) { Object id = message.getValue("id"); - LOG.infof("List tools [id: %s]", id); + LOG.debugf("List tools [id: %s]", id); JsonArray tools = new JsonArray(); for (FeatureMetadata toolMetadata : toolManager.list()) { @@ -73,7 +73,7 @@ void toolsCall(JsonObject message, Responder responder, McpConnection connection Object id = message.getValue("id"); JsonObject params = message.getJsonObject("params"); String toolName = params.getString("name"); - LOG.infof("Call tool %s [id: %s]", toolName, id); + LOG.debugf("Call tool %s [id: %s]", toolName, id); ArgumentProviders argProviders = new ArgumentProviders(params.getJsonObject("arguments").getMap(), connection, id); diff --git a/transports/sse/runtime/src/main/java/io/quarkiverse/mcp/server/sse/runtime/SseMcpServerRecorder.java b/transports/sse/runtime/src/main/java/io/quarkiverse/mcp/server/sse/runtime/SseMcpServerRecorder.java index 2d826d1..e576545 100644 --- a/transports/sse/runtime/src/main/java/io/quarkiverse/mcp/server/sse/runtime/SseMcpServerRecorder.java +++ b/transports/sse/runtime/src/main/java/io/quarkiverse/mcp/server/sse/runtime/SseMcpServerRecorder.java @@ -53,7 +53,7 @@ public void handle(RoutingContext ctx) { String id = Base64.getUrlEncoder().encodeToString(UUID.randomUUID().toString().getBytes()); - LOG.infof("Client connection initialized [%s]", id); + LOG.debugf("Client connection initialized [%s]", id); SseMcpConnection connection = new SseMcpConnection(id, response); connectionManager.add(connection); @@ -83,7 +83,7 @@ public void handle(Void event) { closeHandler.handle(event); } if (connectionManager.remove(connectionId)) { - LOG.infof("Connection %s closed", connectionId); + LOG.debugf("Connection %s closed", connectionId); } // Connection may have been removed earlier... }