File tree Expand file tree Collapse file tree 1 file changed +9
-3
lines changed
core/src/main/java/com/google/adk/tools/mcp Expand file tree Collapse file tree 1 file changed +9
-3
lines changed Original file line number Diff line number Diff line change 2222import io .modelcontextprotocol .spec .McpSchema .ClientCapabilities ;
2323import io .modelcontextprotocol .spec .McpSchema .InitializeResult ;
2424import java .time .Duration ;
25+ import java .util .Optional ;
2526import org .slf4j .Logger ;
2627import org .slf4j .LoggerFactory ;
2728
@@ -51,16 +52,21 @@ public static McpSyncClient initializeSession(Object connectionParams) {
5152
5253 public static McpSyncClient initializeSession (
5354 Object connectionParams , McpTransportBuilder transportBuilder ) {
55+ Duration initializationTimeout = null ;
56+ Duration requestTimeout = null ;
5457 McpClientTransport transport = transportBuilder .build (connectionParams );
55-
58+ if (connectionParams instanceof SseServerParameters sseServerParams ) {
59+ initializationTimeout = sseServerParams .timeout ();
60+ requestTimeout = sseServerParams .sseReadTimeout ();
61+ }
5662 McpSyncClient client =
5763 McpClient .sync (transport )
58- .requestTimeout (Duration .ofSeconds (10 ))
64+ .initializationTimeout (Optional .ofNullable (initializationTimeout ).orElse (Duration .ofSeconds (10 )))
65+ .requestTimeout (Optional .ofNullable (requestTimeout ).orElse (Duration .ofSeconds (10 )))
5966 .capabilities (ClientCapabilities .builder ().build ())
6067 .build ();
6168 InitializeResult initResult = client .initialize ();
6269 logger .debug ("Initialize Client Result: {}" , initResult );
63-
6470 return client ;
6571 }
6672}
You can’t perform that action at this time.
0 commit comments