Skip to content

Commit 6757594

Browse files
authored
Merge pull request #1626 from diegolovison/issue_1624
Set configurable timeout for transports
2 parents 30b20ad + 00d7a28 commit 6757594

File tree

1 file changed

+2
-0
lines changed
  • mcp/runtime/src/main/java/io/quarkiverse/langchain4j/mcp/runtime

1 file changed

+2
-0
lines changed

mcp/runtime/src/main/java/io/quarkiverse/langchain4j/mcp/runtime/McpRecorder.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,7 @@ public McpClient get() {
7575
.logRequests(runtimeConfig.logRequests().orElse(false))
7676
.logResponses(runtimeConfig.logResponses().orElse(false))
7777
.mcpClientName(key)
78+
.timeout(runtimeConfig.toolExecutionTimeout())
7879
.build();
7980
case STREAMABLE_HTTP -> new QuarkusStreamableHttpMcpTransport.Builder()
8081
.url(runtimeConfig.url().orElseThrow(() -> new ConfigurationException(
@@ -83,6 +84,7 @@ public McpClient get() {
8384
.logResponses(runtimeConfig.logResponses().orElse(false))
8485
.httpClient(vertx.get().createHttpClient())
8586
.mcpClientName(key)
87+
.timeout(runtimeConfig.toolExecutionTimeout())
8688
.build();
8789
};
8890
DefaultMcpClient client = new DefaultMcpClient.Builder()

0 commit comments

Comments
 (0)