Class McpAsyncTool

java.lang.Object

com.google.adk.tools.BaseTool

com.google.adk.tools.mcp.AbstractMcpTool<io.modelcontextprotocol.client.McpAsyncClient>

com.google.adk.tools.mcp.McpAsyncTool

public final class McpAsyncTool
extends AbstractMcpTool<io.modelcontextprotocol.client.McpAsyncClient>

Initializes a MCP tool.

This wraps a MCP Tool interface and an active MCP Session. It invokes the MCP Tool through executing the tool from remote MCP Session.

Nested Class Summary

Nested classes/interfaces inherited from class BaseTool

BaseTool.ToolArgsConfig, BaseTool.ToolConfig

Modifier and Type	Class	Description
static class	BaseTool.ToolArgsConfig	Configuration class for tool arguments that allows arbitrary key-value pairs.
static class	BaseTool.ToolConfig	Configuration class for a tool definition in YAML/JSON.

Field Summary

Fields inherited from class AbstractMcpTool

mcpSession, mcpSessionManager, mcpTool, objectMapper

Modifier and Type	Field	Description
protected io.modelcontextprotocol.client.McpAsyncClient	mcpSession
protected final McpSessionManager	mcpSessionManager
protected final io.modelcontextprotocol.spec.McpSchema.Tool	mcpTool
protected final com.fasterxml.jackson.databind.ObjectMapper	objectMapper

Constructor Summary

Constructors

Constructor	Description
McpAsyncTool(io.modelcontextprotocol.spec.McpSchema.Tool mcpTool, io.modelcontextprotocol.client.McpAsyncClient mcpSession, McpSessionManager mcpSessionManager)	Creates a new McpAsyncTool with the default ObjectMapper.
McpAsyncTool(io.modelcontextprotocol.spec.McpSchema.Tool mcpTool, io.modelcontextprotocol.client.McpAsyncClient mcpSession, McpSessionManager mcpSessionManager, com.fasterxml.jackson.databind.ObjectMapper objectMapper)	Creates a new McpAsyncTool

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Single<Map<String,Object>>	runAsync(Map<String,Object> args, ToolContext toolContext)	Calls a tool.

Methods inherited from class AbstractMcpTool

annotations, declaration, getMcpSession, meta, wrapCallResult

Modifier and Type	Method	Description
io.modelcontextprotocol.spec.McpSchema.ToolAnnotations	annotations()
Optional<com.google.genai.types.FunctionDeclaration>	declaration()	Gets the FunctionDeclaration representation of this tool.
io.modelcontextprotocol.client.McpAsyncClient	getMcpSession()
Map<String,Object>	meta()
protected static Map<String,Object>	wrapCallResult(com.fasterxml.jackson.databind.ObjectMapper objectMapper, String mcpToolName, io.modelcontextprotocol.spec.McpSchema.CallToolResult callResult)

Methods inherited from class BaseTool

customMetadata, description, fromConfig, longRunning, name, processLlmRequest, runAsync, runAsync, runAsync, runAsync, runAsync, runAsync, setCustomMetadata

Modifier and Type	Method	Description
com.google.common.collect.ImmutableMap<String,Object>	customMetadata()	Returns a read-only view of the tool metadata.
String	description()
static BaseTool	fromConfig(BaseTool.ToolConfig config, String configAbsPath)	Creates a tool instance from a config.
boolean	longRunning()
String	name()
io.reactivex.rxjava3.core.Completable	processLlmRequest(LlmRequest.Builder llmRequestBuilder, ToolContext toolContext)	Processes the outgoing LlmRequest.Builder.
final <I,O> io.reactivex.rxjava3.core.Single<O>	runAsync(I args, ToolContext toolContext, com.fasterxml.jackson.core.type.TypeReference<? extends O> typeReference)	Calls a tool with generic arguments, returning the results converted to a specified type reference.
final <I,O> io.reactivex.rxjava3.core.Single<O>	runAsync(I args, ToolContext toolContext, com.fasterxml.jackson.databind.ObjectMapper objectMapper, com.fasterxml.jackson.core.type.TypeReference<? extends O> typeReference)	Calls a tool with generic arguments and a custom ObjectMapper, returning the results converted to a specified type reference.
final <I,O> io.reactivex.rxjava3.core.Single<O>	runAsync(I args, ToolContext toolContext, com.fasterxml.jackson.databind.ObjectMapper objectMapper, Class<? extends O> oClass)	Calls a tool with generic arguments and a custom ObjectMapper, returning the results converted to a specified class.
final <I,O> io.reactivex.rxjava3.core.Single<O>	runAsync(I args, ToolContext toolContext, Class<? extends O> oClass)	Calls a tool with generic arguments, returning the results converted to a specified class.
final <T> io.reactivex.rxjava3.core.Single<Map<String,Object>>	runAsync(T args, ToolContext toolContext)	Calls a tool with generic arguments and returns a map of results.
final <T> io.reactivex.rxjava3.core.Single<Map<String,Object>>	runAsync(T args, ToolContext toolContext, com.fasterxml.jackson.databind.ObjectMapper objectMapper)	Calls a tool with generic arguments using a custom ObjectMapper and returns a map of results.
void	setCustomMetadata(String key, Object value)	Sets custom metadata to the tool associated with a key.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

McpAsyncTool

public McpAsyncTool(io.modelcontextprotocol.spec.McpSchema.Tool mcpTool,
 io.modelcontextprotocol.client.McpAsyncClient mcpSession,
 McpSessionManager mcpSessionManager)

Creates a new McpAsyncTool with the default ObjectMapper.

Parameters:

mcpTool - The MCP tool to wrap.

mcpSession - The MCP session to use to call the tool.

mcpSessionManager - The MCP session manager to use to create new sessions.

Throws:

IllegalArgumentException - If mcpTool or mcpSession are null.

McpAsyncTool

public McpAsyncTool(io.modelcontextprotocol.spec.McpSchema.Tool mcpTool,
 io.modelcontextprotocol.client.McpAsyncClient mcpSession,
 McpSessionManager mcpSessionManager,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Creates a new McpAsyncTool

Parameters:

mcpTool - The MCP tool to wrap.

mcpSession - The MCP session to use to call the tool.

mcpSessionManager - The MCP session manager to use to create new sessions.

objectMapper - The ObjectMapper to use to convert JSON schemas.

Throws:

IllegalArgumentException - If mcpTool or mcpSession are null.

Method Details

runAsync

public io.reactivex.rxjava3.core.Single<Map<String,Object>> runAsync(Map<String,Object> args,
 ToolContext toolContext)

Description copied from class: BaseTool

Calls a tool.

Overrides:

runAsync in class BaseTool