Class DockerMcpTransport

java.lang.Object

dev.langchain4j.mcp.client.transport.docker.DockerMcpTransport

All Implemented Interfaces:

dev.langchain4j.mcp.client.transport.McpTransport, Closeable, AutoCloseable

public class DockerMcpTransport
extends Object
implements dev.langchain4j.mcp.client.transport.McpTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DockerMcpTransport.Builder

Constructor Summary

Constructors

Constructor	Description
DockerMcpTransport(DockerMcpTransport.Builder builder)

Method Summary

Modifier and Type	Method	Description
static DockerMcpTransport.Builder	builder()
void	checkHealth()
void	close()
void	executeOperationWithoutResponse(dev.langchain4j.mcp.client.McpCallContext context)
void	executeOperationWithoutResponse(dev.langchain4j.mcp.protocol.McpClientMessage operation)
CompletableFuture<com.fasterxml.jackson.databind.JsonNode>	executeOperationWithResponse(dev.langchain4j.mcp.client.McpCallContext context)
CompletableFuture<com.fasterxml.jackson.databind.JsonNode>	executeOperationWithResponse(dev.langchain4j.mcp.protocol.McpClientMessage operation)
CompletableFuture<com.fasterxml.jackson.databind.JsonNode>	initialize(dev.langchain4j.mcp.protocol.McpInitializeRequest operation)
void	onFailure(Runnable actionOnFailure)
void	start(dev.langchain4j.mcp.client.transport.McpOperationHandler messageHandler)

Methods inherited from class Object

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

Constructor Details

DockerMcpTransport

public DockerMcpTransport(DockerMcpTransport.Builder builder)

Method Details

start

public void start(dev.langchain4j.mcp.client.transport.McpOperationHandler messageHandler)

Specified by:

start in interface dev.langchain4j.mcp.client.transport.McpTransport

initialize

public CompletableFuture<com.fasterxml.jackson.databind.JsonNode> initialize(dev.langchain4j.mcp.protocol.McpInitializeRequest operation)

Specified by:

initialize in interface dev.langchain4j.mcp.client.transport.McpTransport

executeOperationWithResponse

public CompletableFuture<com.fasterxml.jackson.databind.JsonNode> executeOperationWithResponse(dev.langchain4j.mcp.protocol.McpClientMessage operation)

Specified by:

executeOperationWithResponse in interface dev.langchain4j.mcp.client.transport.McpTransport

executeOperationWithResponse

public CompletableFuture<com.fasterxml.jackson.databind.JsonNode> executeOperationWithResponse(dev.langchain4j.mcp.client.McpCallContext context)

Specified by:

executeOperationWithResponse in interface dev.langchain4j.mcp.client.transport.McpTransport

executeOperationWithoutResponse

public void executeOperationWithoutResponse(dev.langchain4j.mcp.protocol.McpClientMessage operation)

Specified by:

executeOperationWithoutResponse in interface dev.langchain4j.mcp.client.transport.McpTransport

executeOperationWithoutResponse

public void executeOperationWithoutResponse(dev.langchain4j.mcp.client.McpCallContext context)

Specified by:

executeOperationWithoutResponse in interface dev.langchain4j.mcp.client.transport.McpTransport

checkHealth

public void checkHealth()

Specified by:

checkHealth in interface dev.langchain4j.mcp.client.transport.McpTransport

onFailure

public void onFailure(Runnable actionOnFailure)

Specified by:

onFailure in interface dev.langchain4j.mcp.client.transport.McpTransport

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

builder

public static DockerMcpTransport.Builder builder()