io.modelcontextprotocol.spec

类 DefaultMcpTransportSession

java.lang.Object

io.modelcontextprotocol.spec.DefaultMcpTransportSession

所有已实现的接口:

McpTransportSession<reactor.core.Disposable>

public class DefaultMcpTransportSession
extends java.lang.Object
implements McpTransportSession<reactor.core.Disposable>

Default implementation of McpTransportSession which manages the open connections using tye Disposable type and allows to perform clean up using the Disposable.dispose() method.

构造器概要

构造器

构造器和说明
DefaultMcpTransportSession(java.util.function.Function<java.lang.String,org.reactivestreams.Publisher<java.lang.Void>> onClose)

方法概要

限定符和类型	方法和说明
void	addConnection(reactor.core.Disposable connection) Adds a resource that this transport session can monitor and dismiss when needed.
void	close() Close and clear the monitored resources.
reactor.core.publisher.Mono<java.lang.Void>	closeGracefully() Close and clear the monitored resources in a graceful manner.
boolean	markInitialized(java.lang.String sessionId) Stateful operation that flips the un-initialized state to initialized if this is the first call.
void	removeConnection(reactor.core.Disposable connection) Called when the resource is terminating by itself and the transport session does not need to track it anymore.
java.util.Optional<java.lang.String>	sessionId() In case of stateful MCP servers, the value is present and contains the String identifier for the transport-level session.

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

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

构造器详细资料

DefaultMcpTransportSession

public DefaultMcpTransportSession(java.util.function.Function<java.lang.String,org.reactivestreams.Publisher<java.lang.Void>> onClose)

方法详细资料

sessionId

public java.util.Optional<java.lang.String> sessionId()

从接口复制的说明: McpTransportSession

In case of stateful MCP servers, the value is present and contains the String identifier for the transport-level session.

指定者:

sessionId 在接口中 McpTransportSession<reactor.core.Disposable>

返回:

optional session id

markInitialized

public boolean markInitialized(java.lang.String sessionId)

从接口复制的说明: McpTransportSession

Stateful operation that flips the un-initialized state to initialized if this is the first call. If the transport provides a session id for the communication, argument should not be null to record the current identifier.

指定者:

markInitialized 在接口中 McpTransportSession<reactor.core.Disposable>

参数:

sessionId - session identifier as provided by the server

返回:

if successful, this method returns true and means that a post-initialization step can be performed

addConnection

public void addConnection(reactor.core.Disposable connection)

从接口复制的说明: McpTransportSession

Adds a resource that this transport session can monitor and dismiss when needed.

指定者:

addConnection 在接口中 McpTransportSession<reactor.core.Disposable>

参数:

connection - the managed resource

removeConnection

public void removeConnection(reactor.core.Disposable connection)

从接口复制的说明: McpTransportSession

Called when the resource is terminating by itself and the transport session does not need to track it anymore.

指定者:

removeConnection 在接口中 McpTransportSession<reactor.core.Disposable>

参数:

connection - the resource to remove from the monitored collection

close

public void close()

从接口复制的说明: McpTransportSession

Close and clear the monitored resources. Potentially asynchronous.

指定者:

close 在接口中 McpTransportSession<reactor.core.Disposable>

closeGracefully

public reactor.core.publisher.Mono<java.lang.Void> closeGracefully()

从接口复制的说明: McpTransportSession

Close and clear the monitored resources in a graceful manner.

指定者:

closeGracefully 在接口中 McpTransportSession<reactor.core.Disposable>

返回:

completes once all resources have been dismissed