Package dev.tachyonmcp.core.transport.netty

@NullMarked @InternalApi package dev.tachyonmcp.core.transport.netty

Netty-based HTTP and SSE transport implementation.

Related Packages

Package	Description
dev.tachyonmcp.core.transport	MCP transport layer — HTTP/SSE protocol handling, JSON-RPC encoding, and connection management.
dev.tachyonmcp.core.transport.netty.http	Netty HTTP channel initialization and pipeline configuration.
dev.tachyonmcp.core.transport.netty.sse	Netty Server-Sent Events (SSE) transport for MCP streamable HTTP.
dev.tachyonmcp.core.transport.jsonrpc	JSON-RPC 2.0 message parsing, serialization, and codec types.

Class	Description
ChannelHandlerUtils
InteractionHandler	Creates and manages the per-channel ChannelContext on channel active/inactive lifecycle events.
LifecyclePipelineCoordinator
McpChannelInitializer	Assembles the Netty pipeline for each new MCP channel: validation handlers (endpoint, origin, protocol version, accept header, stateless guard), InteractionHandler, HTTP aggregation, idle timeout, the initialization-phase handler (McpInitializationHandler), and the LifecyclePipelineCoordinator.
McpHandlerManager
McpInitializationHandler	Handles the INITIALIZATION lifecycle phase of an MCP connection.
McpOperationHandler	Handles MCP requests during the OPERATION lifecycle phase: all JSON-RPC methods after the initial initialize handshake.
McpResponseWriter
NettyIoEngine	A Netty I/O transport engine — pairs an IoHandlerFactory with a ServerSocketChannel class.
NettyServer	Netty-based MCP server with Streamable HTTP transport.
NettyServerConfig	Configuration for the Netty transport.
ProtocolHandlerManager
ProtocolVersionHandler	Negotiates the protocol for each MCP POST and binds it to the interaction context.
SessionTouchHandler	Outbound handler that refreshes session liveness on every byte written to the channel.
UnsupportedProtocolVersionHandler	Rejects requests ProtocolVersionHandler flagged as naming an unsupported protocol version, once http-aggregator has assembled the body, so the JSON-RPC id the UnsupportedProtocolVersionError echoes back can be read from it (SEP-2575: error responses MUST carry the request's id).