Skip to content

Commit b9296cb

Browse files
committed
修改onToolAdded()抛出异常
1 parent b415e0d commit b9296cb

File tree

2 files changed

+4
-8
lines changed

2 files changed

+4
-8
lines changed

framework/fel/java/plugins/tool-mcp-server/src/main/java/modelengine/fel/tool/mcp/server/support/DefaultMcpStreamableServer.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -112,13 +112,9 @@ public void onToolAdded(String name, String description, Map<String, Object> par
112112
})
113113
.build();
114114

115-
try {
116-
this.mcpSyncServer.addTool(toolSpecification);
117-
log.info("Tool added to MCP server. [toolName={}, description={}, schema={}]", name, description, parameters);
118-
this.toolsChangedObservers.forEach(ToolsChangedObserver::onToolsChanged);
119-
} catch (Exception e) {
120-
log.error("Failed to add tool to MCP server. [toolName={}]", name, e);
121-
}
115+
this.mcpSyncServer.addTool(toolSpecification);
116+
log.info("Tool added to MCP server. [toolName={}, description={}, schema={}]", name, description, parameters);
117+
this.toolsChangedObservers.forEach(ToolsChangedObserver::onToolsChanged);
122118
}
123119

124120
@Override

framework/fel/java/plugins/tool-mcp-server/src/main/java/modelengine/fel/tool/mcp/server/transport/FitMcpStreamableServerTransportProvider.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -516,8 +516,8 @@ else if (map.containsKey("result") || map.containsKey("error")) {
516516
*/
517517
private class FitStreamableMcpSessionTransport implements McpStreamableServerTransport {
518518
private final String sessionId;
519-
private final HttpClassicServerResponse response;
520519
private final Emitter<TextEvent> emitter;
520+
private final HttpClassicServerResponse response;
521521

522522
private final ReentrantLock lock = new ReentrantLock();
523523

0 commit comments

Comments
 (0)