We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 076c214 commit 0fef925Copy full SHA for 0fef925
src/main/java/spring/ai/mcp/client/McpAsyncClient.java
@@ -57,7 +57,7 @@ public Mono<McpSchema.InitializeResult> initialize() {
57
this.sendRequest("initialize", initializeRequest, new TypeReference<McpSchema.InitializeResult>() {});
58
59
return result.flatMap(initializeResult -> {
60
- if (initializeResult.protocolVersion() != McpSchema.LATEST_PROTOCOL_VERSION) {
+ if (!McpSchema.LATEST_PROTOCOL_VERSION.equals(initializeResult.protocolVersion())) {
61
return Mono.error(
62
new McpError("Unsupported protocol version from the server: "
63
+ initializeResult.protocolVersion()));
0 commit comments