Package dev.tachyonmcp.core.server

Class McpDispatcher

java.lang.Object

dev.tachyonmcp.core.server.McpDispatcher

@InternalApi
public class McpDispatcher
extends Object

Orchestrates the MCP server's per-request flow: parses JSON-RPC messages, establishes the session on initialize, routes to registered handlers (including extension methods), tracks pending requests, and encodes responses. Collaborator of DefaultTachyonServer — server holds state/registries, this drives one request at a time.

MCP- and spec-version-specific: it special-cases initialize/task-status and binds the v2025_11_25 models/codecs. The version-specific call-sites (marked below) move behind an McpDialect when a second spec version is wired.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	McpDispatcher.DispatchResult

Field Summary

Fields

Modifier and Type	Field	Description
static final AttributeKey<io.netty.handler.codec.http.HttpRequest>	ATTR_INIT_REQUEST	Interaction-context attribute key under which McpInitializationHandler stashes a detached copy of the initialize HTTP request, so a custom SessionIdGenerator can read its headers/URI.
static final String	NOTIFICATIONS_INITIALIZED

Constructor Summary

Constructors

Constructor	Description
McpDispatcher(ServerEngine server, Executor executor)

Method Summary

Modifier and Type	Method	Description
McpDispatcher.DispatchResult	dispatchNotification(String method, @Nullable Object params, @Nullable String sessionId)
McpDispatcher.DispatchResult	dispatchNotification(String method, @Nullable Object params, @Nullable String sessionId, @Nullable ChannelContext channelContext)
CompletableFuture<McpDispatcher.DispatchResult>	dispatchRequestAsync(RequestId id, String method, Object params, @Nullable String sessionId)
CompletableFuture<McpDispatcher.DispatchResult>	dispatchRequestAsync(RequestId id, String method, Object params, @Nullable String sessionId, @Nullable OutboundSseStream outboundSseStream, @Nullable ChannelContext channelContext)
byte[]	parseError(@Nullable ChannelContext channelContext)
@Nullable JsonRpcMessage	parseMessage(io.netty.buffer.ByteBuf body)

Methods inherited from class java.lang.Object

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

Field Details

ATTR_INIT_REQUEST

public static final AttributeKey<io.netty.handler.codec.http.HttpRequest> ATTR_INIT_REQUEST

Interaction-context attribute key under which McpInitializationHandler stashes a detached copy of the initialize HTTP request, so a custom SessionIdGenerator can read its headers/URI.

NOTIFICATIONS_INITIALIZED

public static final String NOTIFICATIONS_INITIALIZED

See Also:

• Constant Field Values

Constructor Details

McpDispatcher

public McpDispatcher(ServerEngine server,
 Executor executor)

Method Details

parseMessage

public @Nullable JsonRpcMessage parseMessage(io.netty.buffer.ByteBuf body)

parseError

public byte[] parseError(@Nullable ChannelContext channelContext)

dispatchRequestAsync

public CompletableFuture<McpDispatcher.DispatchResult> dispatchRequestAsync(RequestId id,
 String method,
 Object params,
 @Nullable String sessionId)

dispatchRequestAsync

public CompletableFuture<McpDispatcher.DispatchResult> dispatchRequestAsync(RequestId id,
 String method,
 Object params,
 @Nullable String sessionId,
 @Nullable OutboundSseStream outboundSseStream,
 @Nullable ChannelContext channelContext)

dispatchNotification

public McpDispatcher.DispatchResult dispatchNotification(String method,
 @Nullable Object params,
 @Nullable String sessionId)

dispatchNotification

public McpDispatcher.DispatchResult dispatchNotification(String method,
 @Nullable Object params,
 @Nullable String sessionId,
 @Nullable ChannelContext channelContext)