Skip to content

Commit 1025d61

Browse files
committed
fix(A2AClientConsumer): increase timeout for message response handling #443
1 parent 751a70a commit 1025d61

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/kotlin/cc/unitmesh/devti/a2a/A2AClientConsumer.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ class A2AClientConsumer {
7575

7676
client.sendMessage(message, null)
7777

78-
responseFuture.get(30, java.util.concurrent.TimeUnit.SECONDS)
78+
responseFuture.get(120, java.util.concurrent.TimeUnit.SECONDS)
7979
} catch (e: Exception) {
8080
responseMap.remove(agentName)
8181
logger<A2AClientConsumer>().error("Failed to send message to $agentName: ${e.message}", e)

0 commit comments

Comments
 (0)