modelcontextprotocol/java-sdk
Watch
1
0
Fork
You've already forked java-sdk
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

refactor(webmvc): Rename messageBaseUrl to baseUrl for consistency

Browse source 
Signed-off-by: Christian Tzolov <christian.tzolov@broadcom.com>
This commit is contained in:
Christian Tzolov 2025-04-06 16:33:25 +02:00
commit b21cfab10e
1 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

14
mcp-spring/mcp-spring-webmvc/src/main/java/io/modelcontextprotocol/server/transport/WebMvcSseServerTransportProvider.java
View file

@ -91,7 +91,7 @@ public class WebMvcSseServerTransportProvider implements McpServerTransportProvi
private final String sseEndpoint; private final String sseEndpoint;
private final String messageBaseUrl; private final String baseUrl;
private final RouterFunction<ServerResponse> routerFunction; private final RouterFunction<ServerResponse> routerFunction;
@ -139,23 +139,23 @@ public class WebMvcSseServerTransportProvider implements McpServerTransportProvi
* Constructs a new WebMvcSseServerTransportProvider instance. * Constructs a new WebMvcSseServerTransportProvider instance.
* @param objectMapper The ObjectMapper to use for JSON serialization/deserialization * @param objectMapper The ObjectMapper to use for JSON serialization/deserialization
* of messages. * of messages.
* @param messageBaseUrl The base URL for the message endpoint, used to construct the * @param baseUrl The base URL for the message endpoint, used to construct the full
* full endpoint URL for clients. * endpoint URL for clients.
* @param messageEndpoint The endpoint URI where clients should send their JSON-RPC * @param messageEndpoint The endpoint URI where clients should send their JSON-RPC
* messages via HTTP POST. This endpoint will be communicated to clients through the * messages via HTTP POST. This endpoint will be communicated to clients through the
* SSE connection's initial endpoint event. * SSE connection's initial endpoint event.
* @param sseEndpoint The endpoint URI where clients establish their SSE connections. * @param sseEndpoint The endpoint URI where clients establish their SSE connections.
* @throws IllegalArgumentException if any parameter is null * @throws IllegalArgumentException if any parameter is null
*/ */
public WebMvcSseServerTransportProvider(ObjectMapper objectMapper, String messageBaseUrl, String messageEndpoint, public WebMvcSseServerTransportProvider(ObjectMapper objectMapper, String baseUrl, String messageEndpoint,
String sseEndpoint) { String sseEndpoint) {
Assert.notNull(objectMapper, "ObjectMapper must not be null"); Assert.notNull(objectMapper, "ObjectMapper must not be null");
Assert.notNull(messageBaseUrl, "Message base URL must not be null"); Assert.notNull(baseUrl, "Message base URL must not be null");
Assert.notNull(messageEndpoint, "Message endpoint must not be null"); Assert.notNull(messageEndpoint, "Message endpoint must not be null");
Assert.notNull(sseEndpoint, "SSE endpoint must not be null"); Assert.notNull(sseEndpoint, "SSE endpoint must not be null");
this.objectMapper = objectMapper; this.objectMapper = objectMapper;
this.messageBaseUrl = messageBaseUrl; this.baseUrl = baseUrl;
this.messageEndpoint = messageEndpoint; this.messageEndpoint = messageEndpoint;
this.sseEndpoint = sseEndpoint; this.sseEndpoint = sseEndpoint;
this.routerFunction = RouterFunctions.route() this.routerFunction = RouterFunctions.route()
@ -269,7 +269,7 @@ public class WebMvcSseServerTransportProvider implements McpServerTransportProvi
try { try {
sseBuilder.id(sessionId) sseBuilder.id(sessionId)
.event(ENDPOINT_EVENT_TYPE) .event(ENDPOINT_EVENT_TYPE)
.data(this.messageBaseUrl + this.messageEndpoint + "?sessionId=" + sessionId); .data(this.baseUrl + this.messageEndpoint + "?sessionId=" + sessionId);
} }
catch (Exception e) { catch (Exception e) {
logger.error("Failed to send initial endpoint event: {}", e.getMessage()); logger.error("Failed to send initial endpoint event: {}", e.getMessage());