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()));