diff --git a/plugins/mcp/pom.xml b/plugins/mcp/pom.xml index db198acd0..f5348e228 100644 --- a/plugins/mcp/pom.xml +++ b/plugins/mcp/pom.xml @@ -35,7 +35,7 @@ Model Context Protocol (MCP) plugin for Genkit - enables integration with MCP servers and tools - 0.17.2 + 1.0.0 false diff --git a/plugins/mcp/src/main/java/com/google/genkit/plugins/mcp/MCPClient.java b/plugins/mcp/src/main/java/com/google/genkit/plugins/mcp/MCPClient.java index 5c6ad7676..3cf308a39 100644 --- a/plugins/mcp/src/main/java/com/google/genkit/plugins/mcp/MCPClient.java +++ b/plugins/mcp/src/main/java/com/google/genkit/plugins/mcp/MCPClient.java @@ -29,6 +29,7 @@ import io.modelcontextprotocol.client.transport.HttpClientStreamableHttpTransport; import io.modelcontextprotocol.client.transport.ServerParameters; import io.modelcontextprotocol.client.transport.StdioClientTransport; +import io.modelcontextprotocol.json.McpJsonDefaults; import io.modelcontextprotocol.json.McpJsonMapper; import io.modelcontextprotocol.spec.McpClientTransport; import io.modelcontextprotocol.spec.McpSchema; @@ -299,7 +300,7 @@ public boolean isConnected() { // Private methods private McpClientTransport createTransport() { - McpJsonMapper jsonMapper = McpJsonMapper.getDefault(); + McpJsonMapper jsonMapper = McpJsonDefaults.getMapper(); switch (config.getTransportType()) { case STDIO: diff --git a/plugins/mcp/src/main/java/com/google/genkit/plugins/mcp/MCPServer.java b/plugins/mcp/src/main/java/com/google/genkit/plugins/mcp/MCPServer.java index 824892694..340b075ff 100644 --- a/plugins/mcp/src/main/java/com/google/genkit/plugins/mcp/MCPServer.java +++ b/plugins/mcp/src/main/java/com/google/genkit/plugins/mcp/MCPServer.java @@ -24,6 +24,7 @@ import com.google.genkit.core.ActionType; import com.google.genkit.core.GenkitException; import com.google.genkit.core.Registry; +import io.modelcontextprotocol.json.McpJsonDefaults; import io.modelcontextprotocol.json.McpJsonMapper; import io.modelcontextprotocol.server.McpServer; import io.modelcontextprotocol.server.McpServerFeatures; @@ -75,7 +76,7 @@ public class MCPServer { private static final Logger logger = LoggerFactory.getLogger(MCPServer.class); - private static final McpJsonMapper jsonMapper = McpJsonMapper.getDefault(); + private static final McpJsonMapper jsonMapper = McpJsonDefaults.getMapper(); private final Registry registry; private final MCPServerOptions options;