Package io.modelcontextprotocol.spec

Class DefaultMcpStreamableServerSessionFactory

java.lang.Object

io.modelcontextprotocol.spec.DefaultMcpStreamableServerSessionFactory

All Implemented Interfaces:

McpStreamableServerSession.Factory

public class DefaultMcpStreamableServerSessionFactory
extends Object
implements McpStreamableServerSession.Factory

A default implementation of McpStreamableServerSession.Factory.

Author:

Dariusz Jędrzejczyk

Constructor Summary

Constructors

Constructor	Description
DefaultMcpStreamableServerSessionFactory(Duration requestTimeout, McpStreamableServerSession.InitRequestHandler initRequestHandler, Map<String,McpRequestHandler<?>> requestHandlers, Map<String,McpNotificationHandler> notificationHandlers)	Deprecated. Use DefaultMcpStreamableServerSessionFactory(Duration, McpStreamableServerSession.InitRequestHandler, Map, Map, Function) instead
DefaultMcpStreamableServerSessionFactory(Duration requestTimeout, McpStreamableServerSession.InitRequestHandler initRequestHandler, Map<String,McpRequestHandler<?>> requestHandlers, Map<String,McpNotificationHandler> notificationHandlers, Function<String,reactor.core.publisher.Mono<Void>> onClose)	Constructs an instance.
DefaultMcpStreamableServerSessionFactory(Duration requestTimeout, McpStreamableServerSession.InitRequestHandler initRequestHandler, Map<String,McpRequestHandler<?>> requestHandlers, Map<String,McpNotificationHandler> notificationHandlers, Function<String,reactor.core.publisher.Mono<Void>> onClose, JsonSchemaValidator jsonSchemaValidator)	Constructs an instance.

Method Summary

Modifier and Type	Method	Description
McpStreamableServerSession.McpStreamableServerSessionInit	startSession(McpSchema.InitializeRequest initializeRequest)	Given an initialize request, create a composite for the session initialization

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultMcpStreamableServerSessionFactory

public DefaultMcpStreamableServerSessionFactory(Duration requestTimeout,
 McpStreamableServerSession.InitRequestHandler initRequestHandler,
 Map<String,McpRequestHandler<?>> requestHandlers,
 Map<String,McpNotificationHandler> notificationHandlers,
 Function<String,reactor.core.publisher.Mono<Void>> onClose,
 JsonSchemaValidator jsonSchemaValidator)

Constructs an instance.

Parameters:

requestTimeout - timeout for requests

initRequestHandler - initialization request handler

requestHandlers - map of MCP request handlers keyed by method name

notificationHandlers - map of MCP notification handlers keyed by method name

onClose - reactive callback invoked with the session ID when a session is closed

jsonSchemaValidator - optional validator threaded to sessions user-provided schema validation

DefaultMcpStreamableServerSessionFactory

public DefaultMcpStreamableServerSessionFactory(Duration requestTimeout,
 McpStreamableServerSession.InitRequestHandler initRequestHandler,
 Map<String,McpRequestHandler<?>> requestHandlers,
 Map<String,McpNotificationHandler> notificationHandlers,
 Function<String,reactor.core.publisher.Mono<Void>> onClose)

Constructs an instance.

Parameters:

requestTimeout - timeout for requests

initRequestHandler - initialization request handler

requestHandlers - map of MCP request handlers keyed by method name

notificationHandlers - map of MCP notification handlers keyed by method name

onClose - reactive callback invoked with the session ID when a session is closed

DefaultMcpStreamableServerSessionFactory

@Deprecated
public DefaultMcpStreamableServerSessionFactory(Duration requestTimeout,
 McpStreamableServerSession.InitRequestHandler initRequestHandler,
 Map<String,McpRequestHandler<?>> requestHandlers,
 Map<String,McpNotificationHandler> notificationHandlers)

Deprecated.

Use DefaultMcpStreamableServerSessionFactory(Duration, McpStreamableServerSession.InitRequestHandler, Map, Map, Function) instead

Constructs an instance.

Parameters:

requestTimeout - timeout for requests

initRequestHandler - initialization request handler

requestHandlers - map of MCP request handlers keyed by method name

notificationHandlers - map of MCP notification handlers keyed by method name

Method Details

startSession

public McpStreamableServerSession.McpStreamableServerSessionInit startSession(McpSchema.InitializeRequest initializeRequest)

Description copied from interface: McpStreamableServerSession.Factory

Given an initialize request, create a composite for the session initialization

Specified by:

startSession in interface McpStreamableServerSession.Factory

Parameters:

initializeRequest - the initialization request from the client

Returns:

a composite allowing the session to start