Skip to content

Commit 5fd0744

Browse files
committed
fix: resolve duplicate requests caused by concurrent message sending
1 parent b701a36 commit 5fd0744

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

mcp/src/main/java/io/modelcontextprotocol/client/transport/FlowSseClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,7 @@ public FlowSseClient(HttpClient httpClient, HttpRequest.Builder requestBuilder)
121121
* @throws RuntimeException if the connection fails with a non-200 status code
122122
*/
123123
public void subscribe(String url, SseEventHandler eventHandler) {
124-
HttpRequest request = this.requestBuilder.uri(URI.create(url))
124+
HttpRequest request = this.requestBuilder.copy().uri(URI.create(url))
125125
.header("Accept", "text/event-stream")
126126
.header("Cache-Control", "no-cache")
127127
.GET()

mcp/src/main/java/io/modelcontextprotocol/client/transport/HttpClientSseClientTransport.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -415,7 +415,7 @@ public Mono<Void> sendMessage(JSONRPCMessage message) {
415415
try {
416416
String jsonText = this.objectMapper.writeValueAsString(message);
417417
URI requestUri = Utils.resolveUri(baseUri, endpoint);
418-
HttpRequest request = this.requestBuilder.uri(requestUri)
418+
HttpRequest request = this.requestBuilder.copy().uri(requestUri)
419419
.POST(HttpRequest.BodyPublishers.ofString(jsonText))
420420
.build();
421421

0 commit comments

Comments
 (0)