Skip to content

Commit 4aa02a1

Browse files
committed
SDK版本更新为0.15.0
1 parent 4cf12f9 commit 4aa02a1

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,10 +40,9 @@
4040
<dependency>
4141
<groupId>io.modelcontextprotocol.sdk</groupId>
4242
<artifactId>mcp</artifactId>
43-
<version>0.12.0</version>
43+
<version>0.15.0</version>
4444
</dependency>
4545

46-
4746
<!-- Test -->
4847
<dependency>
4948
<groupId>org.junit.jupiter</groupId>

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

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,10 @@
99
import com.fasterxml.jackson.databind.ObjectMapper;
1010
import io.modelcontextprotocol.client.McpSyncClient;
1111
import io.modelcontextprotocol.client.transport.HttpClientStreamableHttpTransport;
12+
import io.modelcontextprotocol.json.McpJsonMapper;
13+
import io.modelcontextprotocol.json.jackson.JacksonMcpJsonMapper;
14+
import io.modelcontextprotocol.json.schema.JsonSchemaValidator;
15+
import io.modelcontextprotocol.json.schema.jackson.DefaultJsonSchemaValidator;
1216
import io.modelcontextprotocol.spec.McpSchema;
1317
import modelengine.fel.tool.mcp.client.McpClient;
1418
import modelengine.fel.tool.mcp.entity.Tool;
@@ -46,8 +50,9 @@ public class DefaultMcpStreamableClient implements McpClient {
4650
public DefaultMcpStreamableClient(String baseUri, String sseEndpoint, int requestTimeoutSeconds) {
4751
notBlank(baseUri, "The MCP server base URI cannot be blank.");
4852
notBlank(sseEndpoint, "The MCP server SSE endpoint cannot be blank.");
53+
ObjectMapper mapper = new ObjectMapper();
4954
HttpClientStreamableHttpTransport transport = HttpClientStreamableHttpTransport.builder(baseUri)
50-
.objectMapper(new ObjectMapper())
55+
.jsonMapper(new JacksonMcpJsonMapper(mapper))
5156
.endpoint(sseEndpoint)
5257
.build();
5358
this.mcpSyncClient = io.modelcontextprotocol.client.McpClient.sync(transport)
@@ -57,6 +62,7 @@ public DefaultMcpStreamableClient(String baseUri, String sseEndpoint, int reques
5762
.build())
5863
.loggingConsumer(McpClientMessageHandler::handleLoggingMessage)
5964
.elicitation(McpClientMessageHandler::handleElicitationRequest)
65+
.jsonSchemaValidator(new DefaultJsonSchemaValidator(mapper))
6066
.build();
6167
}
6268

0 commit comments

Comments
 (0)