From 0fef9255813a7614962972998543031e124f330b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Dariusz=20J=C4=99drzejczyk?=
 <dariusz.jedrzejczyk@broadcom.com>
Date: Mon, 9 Dec 2024 10:19:35 +0100
Subject: [PATCH] Fix protocol check

---
 src/main/java/spring/ai/mcp/client/McpAsyncClient.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/spring/ai/mcp/client/McpAsyncClient.java b/src/main/java/spring/ai/mcp/client/McpAsyncClient.java
index 0b2813d..03c9f6d 100644
--- a/src/main/java/spring/ai/mcp/client/McpAsyncClient.java
+++ b/src/main/java/spring/ai/mcp/client/McpAsyncClient.java
@@ -57,7 +57,7 @@ public class McpAsyncClient extends McpAsyncSession {
 				this.sendRequest("initialize", initializeRequest, new TypeReference<McpSchema.InitializeResult>() {});
 
 		return result.flatMap(initializeResult -> {
-			if (initializeResult.protocolVersion() != McpSchema.LATEST_PROTOCOL_VERSION) {
+			if (!McpSchema.LATEST_PROTOCOL_VERSION.equals(initializeResult.protocolVersion())) {
 				return Mono.error(
 						new McpError("Unsupported protocol version from the server: "
 								+ initializeResult.protocolVersion()));