#115925 - handle rpc notification from proxy server (#6)

Author: rhishirajnema

mcp-bom/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.modelcontextprotocol.sdk</groupId>
         <artifactId>mcp-parent</artifactId>
-        <version>1.2.0</version>
+        <version>1.3.0</version>
     </parent>
 
     <artifactId>mcp-bom</artifactId>

mcp-spring/mcp-spring-webflux/pom.xml

@@ -6,7 +6,7 @@
 	<parent>
 		<groupId>io.modelcontextprotocol.sdk</groupId>
 		<artifactId>mcp-parent</artifactId>
-		<version>1.2.0</version>
+		<version>1.3.0</version>
 		<relativePath>../../pom.xml</relativePath>
 	</parent>
 	<artifactId>mcp-spring-webflux</artifactId>

mcp-spring/mcp-spring-webmvc/pom.xml

@@ -6,7 +6,7 @@
 	<parent>
 		<groupId>io.modelcontextprotocol.sdk</groupId>
 		<artifactId>mcp-parent</artifactId>
-		<version>1.2.0</version>
+		<version>1.3.0</version>
 		<relativePath>../../pom.xml</relativePath>
 	</parent>
 	<artifactId>mcp-spring-webmvc</artifactId>

mcp-test/pom.xml

@@ -6,7 +6,7 @@
 	<parent>
 		<groupId>io.modelcontextprotocol.sdk</groupId>
 		<artifactId>mcp-parent</artifactId>
-		<version>1.2.0</version>
+		<version>1.3.0</version>
 	</parent>
 	<artifactId>mcp-test</artifactId>
 	<packaging>jar</packaging>

mcp/pom.xml

@@ -6,7 +6,7 @@
 	<parent>
 		<groupId>io.modelcontextprotocol.sdk</groupId>
 		<artifactId>mcp-parent</artifactId>
-		<version>1.2.0</version>
+		<version>1.3.0</version>
 	</parent>
 	<artifactId>mcp</artifactId>
 	<packaging>jar</packaging>

mcp/src/main/java/io/modelcontextprotocol/spec/McpServerSession.java

@@ -213,8 +213,14 @@ else if (message instanceof McpSchema.JSONRPCNotification notification) {
 				// happening first
 				logger.debug("Received notification: {}", notification);
 				// TODO: in case of error, should the POST request be signalled?
-				return handleIncomingNotification(notification)
-					.doOnError(error -> logger.error("Error handling notification: {}", error.getMessage()));
+				if (proxySession) {
+					logger.debug("Sending notification to original server via proxy: {}", notification);
+					return this.transport.sendMessage(notification).then(Mono.empty());
+				}
+				else {
+					return handleIncomingNotification(notification)
+						.doOnError(error -> logger.error("Error handling notification: {}", error.getMessage()));
+				}
 			}
 			else {
 				logger.warn("Received unknown message type: {}", message);

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>io.modelcontextprotocol.sdk</groupId>
     <artifactId>mcp-parent</artifactId>
-    <version>1.2.0</version>
+    <version>1.3.0</version>
 
     <packaging>pom</packaging>
     <url>https://github.com/modelcontextprotocol/java-sdk</url>