com.agentclientprotocol.sdk.spec

接口 AcpTransport

所有已知子接口:

AcpAgentTransport, AcpClientTransport

所有已知实现类:

StdioAcpAgentTransport, StdioAcpClientTransport, WebSocketSolonAcpAgentTransport, WebSocketSolonAcpClientTransport

public interface AcpTransport

Defines the asynchronous transport layer for the Agent Client Protocol (ACP).

The AcpTransport interface provides the foundation for implementing custom transport mechanisms in the Agent Client Protocol. It handles the bidirectional communication between the client and agent components, supporting asynchronous message exchange using JSON-RPC format.

Implementations of this interface are responsible for:

• Managing the lifecycle of the transport connection
• Handling incoming messages and errors from the peer
• Sending outbound messages to the peer

The transport layer is designed to be protocol-agnostic, allowing for various implementations such as STDIO, HTTP, SSE, or custom protocols.

方法概要

限定符和类型	方法和说明
default void	close() Closes the transport connection and releases any associated resources.
reactor.core.publisher.Mono<java.lang.Void>	closeGracefully() Closes the transport connection and releases any associated resources asynchronously.
default java.util.List<java.lang.Integer>	protocolVersions() Returns the list of protocol versions supported by this transport.
reactor.core.publisher.Mono<java.lang.Void>	sendMessage(AcpSchema.JSONRPCMessage message) Sends a message to the peer asynchronously.
<T> T	unmarshalFrom(java.lang.Object data, TypeRef<T> typeRef) Unmarshals the given data into an object of the specified type.

方法详细资料

close

default void close()

Closes the transport connection and releases any associated resources.

This method ensures proper cleanup of resources when the transport is no longer needed. It should handle the graceful shutdown of any active connections.

closeGracefully

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

Closes the transport connection and releases any associated resources asynchronously.

返回:

a Mono that completes when the connection has been closed.

sendMessage

reactor.core.publisher.Mono<java.lang.Void> sendMessage(AcpSchema.JSONRPCMessage message)

Sends a message to the peer asynchronously.

This method handles the transmission of messages to the peer in an asynchronous manner. Messages are sent in JSON-RPC format as specified by the ACP protocol.

参数:

message - the AcpSchema.JSONRPCMessage to be sent to the peer

返回:

a Mono that completes when the message has been sent

unmarshalFrom

<T> T unmarshalFrom(java.lang.Object data,
                    TypeRef<T> typeRef)

Unmarshals the given data into an object of the specified type.

类型参数:

T - the type of the object to unmarshal

参数:

data - the data to unmarshal

typeRef - the type reference for the object to unmarshal

返回:

the unmarshalled object

protocolVersions

default java.util.List<java.lang.Integer> protocolVersions()

Returns the list of protocol versions supported by this transport.

返回:

list of supported protocol versions