com.agentclientprotocol.sdk.spec

类 AcpAgentSession

java.lang.Object

com.agentclientprotocol.sdk.spec.AcpAgentSession

所有已实现的接口:

AcpSession

public class AcpAgentSession
extends java.lang.Object
implements AcpSession

Agent-side implementation of the ACP (Agent Client Protocol) session that manages bidirectional JSON-RPC communication between agents and clients. This is the agent-side counterpart to AcpClientSession.

The session manages:

• Request/response handling with unique message IDs
• Notification processing
• Message timeout management
• Transport layer abstraction
• Single-turn enforcement (only one prompt active at a time per session)

This is the agent-side session that receives requests from clients (initialize, newSession, prompt, etc.) and sends requests to clients (readTextFile, writeTextFile, requestPermission, etc.)

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	AcpAgentSession.AcpError ACP-specific error wrapper for JSON-RPC errors.
static interface	AcpAgentSession.NotificationHandler Functional interface for handling incoming JSON-RPC notifications.
static interface	AcpAgentSession.RequestHandler<T> Functional interface for handling incoming JSON-RPC requests.

构造器概要

构造器

构造器和说明
AcpAgentSession(java.time.Duration requestTimeout, AcpAgentTransport transport, java.util.Map<java.lang.String,AcpAgentSession.RequestHandler<?>> requestHandlers, java.util.Map<java.lang.String,AcpAgentSession.NotificationHandler> notificationHandlers) Creates a new AcpAgentSession with the specified configuration and handlers.

方法概要

限定符和类型	方法和说明
void	close() Closes the session immediately, potentially interrupting pending operations.
reactor.core.publisher.Mono<java.lang.Void>	closeGracefully() Closes the session gracefully, allowing pending operations to complete.
java.lang.String	getActivePromptSessionId() Gets the session ID of the active prompt, if any.
boolean	hasActivePrompt() Checks if there is an active prompt being processed.
reactor.core.publisher.Mono<java.lang.Void>	sendNotification(java.lang.String method, java.lang.Object params) Sends a JSON-RPC notification to the client.
<T> reactor.core.publisher.Mono<T>	sendRequest(java.lang.String method, java.lang.Object requestParams, TypeRef<T> typeRef) Sends a JSON-RPC request to the client and expects a response of type T.

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

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

从接口继承的方法 com.agentclientprotocol.sdk.spec.AcpSession

sendNotification

构造器详细资料

AcpAgentSession

public AcpAgentSession(java.time.Duration requestTimeout,
                       AcpAgentTransport transport,
                       java.util.Map<java.lang.String,AcpAgentSession.RequestHandler<?>> requestHandlers,
                       java.util.Map<java.lang.String,AcpAgentSession.NotificationHandler> notificationHandlers)

Creates a new AcpAgentSession with the specified configuration and handlers.

参数:

requestTimeout - Duration to wait for responses

transport - Transport implementation for message exchange

requestHandlers - Map of method names to request handlers

notificationHandlers - Map of method names to notification handlers

方法详细资料

sendRequest

public <T> reactor.core.publisher.Mono<T> sendRequest(java.lang.String method,
                                                      java.lang.Object requestParams,
                                                      TypeRef<T> typeRef)

Sends a JSON-RPC request to the client and expects a response of type T. This is used for agent→client requests like fs/read_text_file, terminal/*, etc.

指定者:

sendRequest 在接口中 AcpSession

类型参数:

T - the type of the expected response

参数:

method - the name of the method to call on the client

requestParams - the parameters to send with the request

typeRef - the TypeReference describing the expected response type

返回:

a Mono that will emit the response when received

sendNotification

public reactor.core.publisher.Mono<java.lang.Void> sendNotification(java.lang.String method,
                                                                    java.lang.Object params)

Sends a JSON-RPC notification to the client. This is used for agent→client notifications like session/update.

指定者:

sendNotification 在接口中 AcpSession

参数:

method - the name of the notification method

params - the notification parameters

返回:

a Mono that completes when the notification is sent

hasActivePrompt

public boolean hasActivePrompt()

Checks if there is an active prompt being processed.

返回:

true if a prompt is currently active

getActivePromptSessionId

public java.lang.String getActivePromptSessionId()

Gets the session ID of the active prompt, if any.

返回:

the session ID or null if no prompt is active

closeGracefully

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

Closes the session gracefully, allowing pending operations to complete.

指定者:

closeGracefully 在接口中 AcpSession

返回:

A Mono that completes when the session is closed

close

public void close()

Closes the session immediately, potentially interrupting pending operations.

指定者:

close 在接口中 AcpSession