(shenyu) branch master updated: fix(mcp): use configured mapper for correlated responses (#7378)

[liuhongyu]

This is an automated email from the ASF dual-hosted git repository.

Aias00 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shenyu.git


The following commit(s) were added to refs/heads/master by this push:
     new 442597e0b1 fix(mcp): use configured mapper for correlated responses 
(#7378)
442597e0b1 is described below

commit 442597e0b14870ae3579e7b7b94838444b6212bc
Author: cloudbase-ai <aias94cof...@gmail.com>
AuthorDate: Wed Sep 30 14:04:31 2026 +0800

    fix(mcp): use configured mapper for correlated responses (#7378)
    
    Signed-off-by: cloudbase-ai <22498243+cloudbase...@users.noreply.github.com>
    Co-authored-by: cloudbase-ai 
<22498243+cloudbase...@users.noreply.github.com>
---
 .../server/transport/ShenyuStreamableHttpServerTransportProvider.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/shenyu-plugin/shenyu-plugin-mcp-server/src/main/java/org/apache/shenyu/plugin/mcp/server/transport/ShenyuStreamableHttpServerTransportProvider.java
 
b/shenyu-plugin/shenyu-plugin-mcp-server/src/main/java/org/apache/shenyu/plugin/mcp/server/transport/ShenyuStreamableHttpServerTransportProvider.java
index cdb0dc37d5..e827be0158 100644
--- 
a/shenyu-plugin/shenyu-plugin-mcp-server/src/main/java/org/apache/shenyu/plugin/mcp/server/transport/ShenyuStreamableHttpServerTransportProvider.java
+++ 
b/shenyu-plugin/shenyu-plugin-mcp-server/src/main/java/org/apache/shenyu/plugin/mcp/server/transport/ShenyuStreamableHttpServerTransportProvider.java
@@ -838,7 +838,7 @@ public class ShenyuStreamableHttpServerTransportProvider 
implements McpServerTra
                     ? transport.getLastSentMessage(messageId) : null;
             if (Objects.nonNull(messageId) && 
Objects.nonNull(correlatedResponse)) {
                 LOGGER.debug("Retrieved correlated response for message id {} 
on session: {}", messageId, sessionId);
-                return new MessageHandlingResult(200, correlatedResponse, 
sessionId);
+                return createMessageHandlingResult(200, correlatedResponse, 
sessionId);
             } else if (Objects.nonNull(transport) && 
transport.isResponseReady() && Objects.nonNull(transport.getLastSentMessage())) 
{
                 final McpSchema.JSONRPCMessage sentMessage = 
transport.getLastSentMessage();
                 LOGGER.debug("Retrieved captured response from transport for 
session: {}", sessionId);