io.modelcontextprotocol.server.transport

类 WebRxStreamableServerTransportProvider.Builder

java.lang.Object

io.modelcontextprotocol.server.transport.WebRxStreamableServerTransportProvider.Builder

封闭类:

WebRxStreamableServerTransportProvider

public static class WebRxStreamableServerTransportProvider.Builder
extends java.lang.Object

Builder for creating instances of WebRxStreamableServerTransportProvider.

This builder provides a fluent API for configuring and creating instances of WebFluxStreamableServerTransportProvider with custom settings.

方法概要

限定符和类型	方法和说明
WebRxStreamableServerTransportProvider	build() Builds a new instance of WebRxStreamableServerTransportProvider with the configured settings.
WebRxStreamableServerTransportProvider.Builder	contextExtractor(McpTransportContextExtractor<org.noear.solon.core.handle.Context> contextExtractor) Sets the context extractor that allows providing the MCP feature implementations to inspect HTTP transport level metadata that was present at HTTP request processing time.
WebRxStreamableServerTransportProvider.Builder	disallowDelete(boolean disallowDelete) Sets whether the session removal capability is disabled.
WebRxStreamableServerTransportProvider.Builder	jsonMapper(McpJsonMapper jsonMapper) Sets the McpJsonMapper to use for JSON serialization/deserialization of MCP messages.
WebRxStreamableServerTransportProvider.Builder	keepAliveInterval(java.time.Duration keepAliveInterval) Sets the keep-alive interval for the server transport.
WebRxStreamableServerTransportProvider.Builder	messageEndpoint(java.lang.String messageEndpoint) Sets the endpoint URI where clients should send their JSON-RPC messages.

从类继承的方法 java.lang.Object

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

方法详细资料

jsonMapper

public WebRxStreamableServerTransportProvider.Builder jsonMapper(McpJsonMapper jsonMapper)

Sets the McpJsonMapper to use for JSON serialization/deserialization of MCP messages.

参数:

jsonMapper - The McpJsonMapper instance. Must not be null.

返回:

this builder instance

抛出:

java.lang.IllegalArgumentException - if jsonMapper is null

messageEndpoint

public WebRxStreamableServerTransportProvider.Builder messageEndpoint(java.lang.String messageEndpoint)

Sets the endpoint URI where clients should send their JSON-RPC messages.

参数:

messageEndpoint - The message endpoint URI. Must not be null.

返回:

this builder instance

抛出:

java.lang.IllegalArgumentException - if messageEndpoint is null

contextExtractor

public WebRxStreamableServerTransportProvider.Builder contextExtractor(McpTransportContextExtractor<org.noear.solon.core.handle.Context> contextExtractor)

Sets the context extractor that allows providing the MCP feature implementations to inspect HTTP transport level metadata that was present at HTTP request processing time. This allows to extract custom headers and other useful data for use during execution later on in the process.

参数:

contextExtractor - The contextExtractor to fill in a McpTransportContext.

返回:

this builder instance

抛出:

java.lang.IllegalArgumentException - if contextExtractor is null

disallowDelete

public WebRxStreamableServerTransportProvider.Builder disallowDelete(boolean disallowDelete)

Sets whether the session removal capability is disabled.

参数:

disallowDelete - if true, the DELETE endpoint will not be supported and sessions won't be deleted.

返回:

this builder instance

keepAliveInterval

public WebRxStreamableServerTransportProvider.Builder keepAliveInterval(java.time.Duration keepAliveInterval)

Sets the keep-alive interval for the server transport.

参数:

keepAliveInterval - The interval for sending keep-alive messages. If null, no keep-alive will be scheduled.

返回:

this builder instance

build

public WebRxStreamableServerTransportProvider build()

Builds a new instance of WebRxStreamableServerTransportProvider with the configured settings.

返回:

A new WebFluxStreamableServerTransportProvider instance

抛出:

java.lang.IllegalStateException - if required parameters are not set