Class StreamableHttpMcpTransport

java.lang.Object
dev.langchain4j.mcp.client.transport.http.StreamableHttpMcpTransport
All Implemented Interfaces:
McpTransport, Closeable, AutoCloseable
public class StreamableHttpMcpTransport extends Object implements McpTransport

  • Constructor Details

  • Method Details

    • start

      public void start(McpOperationHandler operationHandler)
      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

    • executeOperationWithResponse

      public CompletableFuture<com.fasterxml.jackson.databind.JsonNode> executeOperationWithResponse(McpCallContext context)
      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 - either a client-initiated notification or a response to a server-initiated request.
      Specified by:
      executeOperationWithoutResponse in interface McpTransport

    • executeOperationWithoutResponse

      public void executeOperationWithoutResponse(McpCallContext context)
      Description copied from interface: McpTransport
      Sends a message that does not expect a response from the server - either a client-initiated notification or a response to a server-initiated request.
      Specified by:
      executeOperationWithoutResponse in interface McpTransport

    • checkHealth

      public void checkHealth()
      Description copied from interface: McpTransport
      Performs transport-specific health checks, if applicable. This is called by `McpClient.checkHealth()` as the first check before performing a check by sending a 'ping' over the MCP protocol. The purpose is that the transport may have some specific and faster ways to detect that it is broken, like for example, the STDIO transport can fail the check if it detects that the server subprocess isn't alive anymore.
      Specified by:
      checkHealth in interface McpTransport

    • onFailure

      public void onFailure(Runnable actionOnFailure)
      Specified by:
      onFailure in interface McpTransport

    • getMcpSessionId

      public String getMcpSessionId()
      Returns the MCP session ID assigned by the server, or null if no session has been established yet (or the server does not use sessions). The session ID is captured from the Mcp-Session-Id response header during initialization and reused on subsequent requests via the same header.

    • setMcpSessionId

      public void setMcpSessionId(String mcpSessionId)
      Sets the MCP session ID to be sent on subsequent requests via the Mcp-Session-Id header. This is intended for scenarios where a session obtained elsewhere (for example, in another process or pod) needs to be resumed by this transport, allowing stateless deployments without sticky sessions.

    • close

      public void close() throws IOException
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Throws:
      IOException

    • builder

      public static StreamableHttpMcpTransport.Builder builder()