Class A2ASendMessageExecutor

java.lang.Object

com.google.adk.a2a.A2ASendMessageExecutor

public final class A2ASendMessageExecutor
extends Object

Shared SendMessage execution between HTTP service and other integrations.

**EXPERIMENTAL:** Subject to change, rename, or removal in any future patch release. Do not use in production code.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	A2ASendMessageExecutor.AgentExecutionStrategy

Constructor Summary

Constructors

Constructor	Description
A2ASendMessageExecutor(BaseAgent agent, String appName, Duration agentTimeout)
A2ASendMessageExecutor(InMemorySessionService sessionService, String appName)

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Single<io.a2a.spec.Message>	execute(@Nullable io.a2a.spec.Message request)
io.reactivex.rxjava3.core.Single<io.a2a.spec.Message>	execute(@Nullable io.a2a.spec.Message request, A2ASendMessageExecutor.AgentExecutionStrategy agentExecutionStrategy)

Methods inherited from class Object

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

Constructor Details

A2ASendMessageExecutor

public A2ASendMessageExecutor(InMemorySessionService sessionService,
 String appName)

A2ASendMessageExecutor

public A2ASendMessageExecutor(BaseAgent agent,
 String appName,
 Duration agentTimeout)

Method Details

execute

public io.reactivex.rxjava3.core.Single<io.a2a.spec.Message> execute(@Nullable io.a2a.spec.Message request,
 A2ASendMessageExecutor.AgentExecutionStrategy agentExecutionStrategy)

execute

public io.reactivex.rxjava3.core.Single<io.a2a.spec.Message> execute(@Nullable io.a2a.spec.Message request)