Package dev.langchain4j.mcp.client.transport.stdio

Class StdioMcpTransport

java.lang.Object

dev.langchain4j.mcp.client.transport.stdio.StdioMcpTransport

All Implemented Interfaces:

McpTransport, Closeable, AutoCloseable

public class StdioMcpTransport
extends Object
implements McpTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StdioMcpTransport.Builder

Constructor Summary

Constructors

Constructor	Description
StdioMcpTransport(StdioMcpTransport.Builder builder)

Method Summary

Modifier and Type	Method	Description
void	close()
void	executeOperationWithoutResponse(McpClientMessage operation)	Sends a message that does not expect a response from the server.
CompletableFuture<com.fasterxml.jackson.databind.JsonNode>	executeOperationWithResponse(McpClientMessage operation)	Executes an operation that expects a response from the server.
CompletableFuture<com.fasterxml.jackson.databind.JsonNode>	initialize(McpInitializeRequest operation)	Sends the "initialize" message to the MCP server to negotiate capabilities, supported protocol version etc.
void	start(McpOperationHandler messageHandler)	Creates a connection to the MCP server (runs the server as a subprocess if needed).

Methods inherited from class java.lang.Object

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

Constructor Details

StdioMcpTransport

public StdioMcpTransport(StdioMcpTransport.Builder builder)

Method Details

start

public void start(McpOperationHandler messageHandler)

Description copied from interface: McpTransport

Creates a connection to the MCP server (runs the server as a subprocess if needed). This does NOT yet send the "initialize" message to negotiate capabilities.

Specified by:

start in interface McpTransport

initialize

public CompletableFuture<com.fasterxml.jackson.databind.JsonNode> initialize(McpInitializeRequest operation)

Description copied from interface: McpTransport

Sends the "initialize" message to the MCP server to negotiate capabilities, supported protocol version etc. When this method returns successfully, the transport is fully initialized and ready to be used. This has to be called AFTER the "start" method.

Specified by:

initialize in interface McpTransport

executeOperationWithResponse

public CompletableFuture<com.fasterxml.jackson.databind.JsonNode> executeOperationWithResponse(McpClientMessage operation)

Description copied from interface: McpTransport

Executes an operation that expects a response from the server.

Specified by:

executeOperationWithResponse in interface McpTransport

executeOperationWithoutResponse

public void executeOperationWithoutResponse(McpClientMessage operation)

Description copied from interface: McpTransport

Sends a message that does not expect a response from the server. The 'id' field of the message should be null.

Specified by:

executeOperationWithoutResponse in interface McpTransport

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException