Fix issue, SSE connection will terminate after 30 seconds (DEFAULT).
This commit is contained in:
parent
c69cc18eb6
commit
dac5c545b0
1 changed files with 2 additions and 1 deletions
|
|
@ -5,6 +5,7 @@
|
||||||
package io.modelcontextprotocol.server.transport;
|
package io.modelcontextprotocol.server.transport;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
import java.time.Duration;
|
||||||
import java.util.UUID;
|
import java.util.UUID;
|
||||||
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.concurrent.ConcurrentHashMap;
|
||||||
import java.util.function.Function;
|
import java.util.function.Function;
|
||||||
|
|
@ -228,7 +229,7 @@ public class WebMvcSseServerTransport implements ServerMcpTransport {
|
||||||
logger.error("Failed to poll event from session queue: {}", e.getMessage());
|
logger.error("Failed to poll event from session queue: {}", e.getMessage());
|
||||||
sseBuilder.error(e);
|
sseBuilder.error(e);
|
||||||
}
|
}
|
||||||
});
|
}, Duration.ZERO);
|
||||||
}
|
}
|
||||||
catch (Exception e) {
|
catch (Exception e) {
|
||||||
logger.error("Failed to send initial endpoint event to session {}: {}", sessionId, e.getMessage());
|
logger.error("Failed to send initial endpoint event to session {}: {}", sessionId, e.getMessage());
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue