io.modelcontextprotocol.util

类 KeepAliveScheduler

java.lang.Object

io.modelcontextprotocol.util.KeepAliveScheduler

public class KeepAliveScheduler
extends java.lang.Object

A utility class for scheduling regular keep-alive calls to maintain connections. It sends periodic keep-alive, ping, messages to connected mcp clients to prevent idle timeouts. The pings are sent to all active mcp sessions at regular intervals.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	KeepAliveScheduler.Builder Builder class for creating KeepAliveScheduler instances with fluent API.

方法概要

限定符和类型	方法和说明
static KeepAliveScheduler.Builder	builder(java.util.function.Supplier<reactor.core.publisher.Flux<McpSession>> mcpSessions) Creates a new Builder instance for constructing KeepAliveScheduler.
boolean	isRunning() Checks if the scheduler is currently running.
void	shutdown() Shuts down the scheduler and releases resources.
reactor.core.Disposable	start() Starts regular keepAlive calls with sessions supplier.
void	stop() Stops the currently running keepAlive scheduler.

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

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

方法详细资料

builder

public static KeepAliveScheduler.Builder builder(java.util.function.Supplier<reactor.core.publisher.Flux<McpSession>> mcpSessions)

Creates a new Builder instance for constructing KeepAliveScheduler.

返回:

A new Builder instance

start

public reactor.core.Disposable start()

Starts regular keepAlive calls with sessions supplier.

返回:

Disposable to control the scheduled execution

stop

public void stop()

Stops the currently running keepAlive scheduler.

isRunning

public boolean isRunning()

Checks if the scheduler is currently running.

返回:

true if running, false otherwise

shutdown

public void shutdown()

Shuts down the scheduler and releases resources.