slhaf/Partner
1
0
Fork 0
mirror of https://github.com/slhaf/Partner.git synced 2026-05-12 08:43:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(LocalRunnerClient): close old MCP client while a new client's name is duplicated with the old one

Browse Source
This commit is contained in:
slhafzjw
2026-01-13 23:22:54 +08:00
parent 774e2b6cd5
commit fdf398b86e
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
Partner-Main/src/main/java/work/slhaf/partner/core/action/runner/LocalRunnerClient.java
View File

@@ -1077,6 +1077,12 @@ public class LocalRunnerClient extends RunnerClient {
* @param mcpClientTransportParams MCP Server 的参数 * @param mcpClientTransportParams MCP Server 的参数
*/ */
private void registerMcpClient(String id, McpClientTransportParams mcpClientTransportParams) { private void registerMcpClient(String id, McpClientTransportParams mcpClientTransportParams) {
// 如果已存在同名 client，则需要先获取并关闭
val old = mcpClients.get(id);
if (old != null) {
old.close();
}
val clientTransport = createTransport(mcpClientTransportParams); val clientTransport = createTransport(mcpClientTransportParams);
val timeout = mcpClientTransportParams.timeout; val timeout = mcpClientTransportParams.timeout;
val client = McpClient.sync(clientTransport) val client = McpClient.sync(clientTransport)