因为jsonMapper问题暂时回退0.12.0版本

Author: relat-ivity

framework/fel/java/plugins/tool-mcp-client/pom.xml

@@ -40,7 +40,7 @@
         <dependency>
             <groupId>io.modelcontextprotocol.sdk</groupId>
             <artifactId>mcp</artifactId>
-            <version>0.14.1</version>
+            <version>0.12.0</version>
         </dependency>
 
 

framework/fel/java/plugins/tool-mcp-client/src/main/java/modelengine/fel/tool/mcp/client/support/DefaultMcpClientFactory.java

@@ -6,21 +6,10 @@
 
 package modelengine.fel.tool.mcp.client.support;
 
-import static modelengine.fitframework.inspection.Validation.notNull;
-
-import io.modelcontextprotocol.client.transport.HttpClientStreamableHttpTransport;
-import io.modelcontextprotocol.json.McpJsonMapper;
-import io.modelcontextprotocol.spec.McpSchema;
 import modelengine.fel.tool.mcp.client.McpClient;
 import modelengine.fel.tool.mcp.client.McpClientFactory;
-import modelengine.fit.http.client.HttpClassicClient;
-import modelengine.fit.http.client.HttpClassicClientFactory;
 import modelengine.fitframework.annotation.Component;
-import modelengine.fitframework.annotation.Fit;
 import modelengine.fitframework.annotation.Value;
-import modelengine.fitframework.serialization.ObjectSerializer;
-
-import java.time.Duration;
 
 /**
  * Represents a factory for creating instances of the {@link DefaultMcpStreamableClient}.

framework/fel/java/plugins/tool-mcp-client/src/main/java/modelengine/fel/tool/mcp/client/support/DefaultMcpStreamableClient.java

@@ -6,9 +6,9 @@
 
 package modelengine.fel.tool.mcp.client.support;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import io.modelcontextprotocol.client.McpSyncClient;
 import io.modelcontextprotocol.client.transport.HttpClientStreamableHttpTransport;
-import io.modelcontextprotocol.json.McpJsonMapper;
 import io.modelcontextprotocol.spec.McpSchema;
 import modelengine.fel.tool.mcp.client.McpClient;
 import modelengine.fel.tool.mcp.entity.Tool;
@@ -47,7 +47,7 @@ public DefaultMcpStreamableClient(String baseUri, String sseEndpoint, int reques
         notBlank(baseUri, "The MCP server base URI cannot be blank.");
         notBlank(sseEndpoint, "The MCP server SSE endpoint cannot be blank.");
         HttpClientStreamableHttpTransport transport = HttpClientStreamableHttpTransport.builder(baseUri)
-                .jsonMapper(McpJsonMapper.getDefault())
+                .objectMapper(new ObjectMapper())
                 .endpoint(sseEndpoint)
                 .build();
         this.mcpSyncClient = io.modelcontextprotocol.client.McpClient.sync(transport)
@@ -103,6 +103,7 @@ public List<Tool> getTools() {
                     .collect(Collectors.toList());
 
             log.info("Successfully retrieved {} tools from MCP server.", tools.size());
+            tools.forEach(tool -> log.info("Tool - Name: {}, Description: {}", tool.getName(), tool.getDescription()));
             return tools;
         } catch (Exception e) {
             log.error("Failed to get tools from MCP server: {}", e);

framework/fel/java/plugins/tool-mcp-client/src/main/java/modelengine/fel/tool/mcp/client/support/McpClientMessageHandler.java

@@ -48,7 +48,7 @@ public static McpSchema.ElicitResult handleElicitationRequest(McpSchema.ElicitRe
         if (schema != null && schema.containsKey("properties")) {
             Map<String, Object> properties = (Map<String, Object>) schema.get("properties");
             if (properties.containsKey("message")) {
-                log.info("[ElicitationRequest] Input additional message: ");
+                log.info("[ElicitationRequest] Please input additional message: ");
                 Scanner scanner = new Scanner(System.in);
                 String input = scanner.nextLine();
                 userData.put("message", input);