Index (Java SDK A2A Core 1.2.0.Final API)

A B C D E F G H I J L M N O P Q R S T U V
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

A2AConfigProvider - Interface in org.a2aproject.sdk.server.config: Configuration provider interface for A2A SDK configuration values.
A2AExtensions - Class in org.a2aproject.sdk.server.extensions
A2AExtensions() - Constructor for class org.a2aproject.sdk.server.extensions.A2AExtensions
A2AVersionValidator - Class in org.a2aproject.sdk.server.version: Utility class for validating A2A protocol version compatibility between clients and agents.
A2AVersionValidator() - Constructor for class org.a2aproject.sdk.server.version.A2AVersionValidator
activateExtension(String) - Method in class org.a2aproject.sdk.server.ServerCallContext
add(String, EventQueue) - Method in class org.a2aproject.sdk.server.events.InMemoryQueueManager
add(String, EventQueue) - Method in interface org.a2aproject.sdk.server.events.QueueManager: Adds a queue to the manager with the given task ID.
addArtifact(List<Part<?>>) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Adds an artifact with the given parts to the task.
addArtifact(List<Part<?>>, String, String, Map<String, Object>) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Adds an artifact with the given parts, artifact ID, name, and metadata.
addArtifact(List<Part<?>>, String, String, Map<String, Object>, Boolean, Boolean) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Adds an artifact with all optional parameters.
addDoneCallback(EnhancedRunnable.DoneCallback) - Method in class org.a2aproject.sdk.server.events.EnhancedRunnable
addOnCloseCallback(Runnable) - Method in class org.a2aproject.sdk.server.events.EventQueue.EventQueueBuilder: Adds a callback to be executed when the queue is closed.
addTask(Task) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Adds a custom Task object to be sent to the client.
AgentCardCacheMetadata - Class in org.a2aproject.sdk.server: Provides HTTP caching metadata for Agent Card responses.
AgentCardCacheMetadata(AgentCard, A2AConfigProvider) - Constructor for class org.a2aproject.sdk.server.AgentCardCacheMetadata: Public constructor for testing purposes.
AgentCardValidator - Class in org.a2aproject.sdk.server: Validates AgentCard transport configuration against available transport endpoints.
AgentCardValidator() - Constructor for class org.a2aproject.sdk.server.AgentCardValidator
AgentEmitter - Class in org.a2aproject.sdk.server.tasks: Helper for emitting events from AgentExecutor implementations.
AgentEmitter(RequestContext, EventQueue) - Constructor for class org.a2aproject.sdk.server.tasks.AgentEmitter: Creates a new AgentEmitter for the given request context and event queue.
agentExecutor(AgentExecutor) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler.Builder
AgentExecutor - Interface in org.a2aproject.sdk.server.agentexecution: Core business logic interface for implementing A2A agent functionality.
ArtifactUtils - Class in org.a2aproject.sdk.server.util: Utility functions for creating A2A Artifact objects.
AsyncExecutorProducer - Class in org.a2aproject.sdk.server.util.async
AsyncExecutorProducer() - Constructor for class org.a2aproject.sdk.server.util.async.AsyncExecutorProducer
AsyncUtils - Class in org.a2aproject.sdk.server.util.async
AsyncUtils() - Constructor for class org.a2aproject.sdk.server.util.async.AsyncUtils
attachRelatedTask(Task) - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext: Attaches a related task to this context.
attributes() - Method in record class org.a2aproject.sdk.server.auth.AuthenticatedUser: Returns the value of the attributes record component.
AuthenticatedUser - Record Class in org.a2aproject.sdk.server.auth
AuthenticatedUser(String) - Constructor for record class org.a2aproject.sdk.server.auth.AuthenticatedUser
AuthenticatedUser(String, Map<String, Object>) - Constructor for record class org.a2aproject.sdk.server.auth.AuthenticatedUser: Creates an instance of a AuthenticatedUser record class.
authorizationProvider(TaskAuthorizationProvider) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler.Builder
AuthorizationRequestHandlerDecorator - Class in org.a2aproject.sdk.server.requesthandlers
AuthorizationRequestHandlerDecorator() - Constructor for class org.a2aproject.sdk.server.requesthandlers.AuthorizationRequestHandlerDecorator
AuthorizationRequestHandlerDecorator(RequestHandler, TaskAuthorizationProvider) - Constructor for class org.a2aproject.sdk.server.requesthandlers.AuthorizationRequestHandlerDecorator: Creates an authorization decorator programmatically.
authorizeTaskAccess(String, ServerCallContext, TaskOperation) - Method in class org.a2aproject.sdk.server.requesthandlers.AuthorizationRequestHandlerDecorator
authorizeTaskAccess(String, ServerCallContext, TaskOperation) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler: The authorization is done by the AuthorizationRequestHandlerDecorator
authorizeTaskAccess(String, ServerCallContext, TaskOperation) - Method in interface org.a2aproject.sdk.server.requesthandlers.RequestHandler
awaitQueuePollerStart() - Method in class org.a2aproject.sdk.server.events.EventQueue: Waits for the queue poller to start consuming events.
awaitQueuePollerStart(EventQueue) - Method in class org.a2aproject.sdk.server.events.InMemoryQueueManager
awaitQueuePollerStart(EventQueue) - Method in interface org.a2aproject.sdk.server.events.QueueManager: Waits for the queue's consumer polling to start.

B

BasePushNotificationSender - Class in org.a2aproject.sdk.server.tasks
BasePushNotificationSender() - Constructor for class org.a2aproject.sdk.server.tasks.BasePushNotificationSender: No-args constructor for CDI proxy creation.
BasePushNotificationSender(PushNotificationConfigStore) - Constructor for class org.a2aproject.sdk.server.tasks.BasePushNotificationSender
BasePushNotificationSender(PushNotificationConfigStore, Instance<PushNotificationPayloadFormatter>) - Constructor for class org.a2aproject.sdk.server.tasks.BasePushNotificationSender
BasePushNotificationSender(PushNotificationConfigStore, A2AHttpClient) - Constructor for class org.a2aproject.sdk.server.tasks.BasePushNotificationSender
BasePushNotificationSender(PushNotificationConfigStore, A2AHttpClient, List<PushNotificationPayloadFormatter>) - Constructor for class org.a2aproject.sdk.server.tasks.BasePushNotificationSender
build() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext.Builder: Builds the RequestContext with ID generation and validation.
build() - Method in class org.a2aproject.sdk.server.agentexecution.SimpleRequestContextBuilder
build() - Method in class org.a2aproject.sdk.server.events.EventQueue.EventQueueBuilder: Builds and returns the configured EventQueue.
build() - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler.Builder
builder() - Static method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler
builder(String) - Method in interface org.a2aproject.sdk.server.events.EventQueueFactory: Creates an EventQueueBuilder with the specified taskId context.
Builder() - Constructor for class org.a2aproject.sdk.server.agentexecution.RequestContext.Builder
Builder() - Constructor for class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler.Builder

C

cancel() - Method in class org.a2aproject.sdk.server.events.EventConsumer
cancel() - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as CANCELED.
cancel(Message) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as CANCELED with an optional message.
cancel(RequestContext, AgentEmitter) - Method in interface org.a2aproject.sdk.server.agentexecution.AgentExecutor: Cancels an ongoing agent execution.
CANCEL_TASK - Enum constant in enum class org.a2aproject.sdk.server.auth.TaskOperation
checkCreate(ServerCallContext, TaskOperation) - Method in interface org.a2aproject.sdk.server.auth.TaskAuthorizationProvider: Check whether the current user is allowed to create a new task.
checkRead(ServerCallContext, String, TaskOperation) - Method in interface org.a2aproject.sdk.server.auth.TaskAuthorizationProvider: Check whether the current user is allowed to read the given task.
checkReadAccess(TaskAuthorizationProvider, ServerCallContext, String, TaskOperation) - Static method in interface org.a2aproject.sdk.server.auth.TaskAuthorizationProvider: Fail-closed read-access check that handles absent provider and missing call context.
checkWrite(ServerCallContext, String, TaskOperation) - Method in interface org.a2aproject.sdk.server.auth.TaskAuthorizationProvider: Check whether the current user is allowed to write to the given task.
clearAwaitingFinalEvent() - Method in class org.a2aproject.sdk.server.events.EventQueue: Clears the awaiting final event flag.
close() - Method in class org.a2aproject.sdk.server.events.EventConsumer
close() - Method in class org.a2aproject.sdk.server.events.EventQueue: Closes this event queue gracefully, allowing pending events to be consumed.
close() - Method in class org.a2aproject.sdk.server.util.async.AsyncExecutorProducer
close(boolean) - Method in class org.a2aproject.sdk.server.events.EventQueue: Closes this event queue with control over immediate shutdown.
close(boolean, boolean) - Method in class org.a2aproject.sdk.server.events.EventQueue: Close this queue with control over parent notification (ChildQueue only).
close(String) - Method in class org.a2aproject.sdk.server.events.InMemoryQueueManager
close(String) - Method in interface org.a2aproject.sdk.server.events.QueueManager: Closes and removes the queue for a task.
closeStreams() - Method in interface org.a2aproject.sdk.server.events.StreamCloseHandle: Gracefully closes all active ChildQueues for this task.
complete() - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as COMPLETED.
complete(Message) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as COMPLETED with an optional message.
consumeAll() - Method in class org.a2aproject.sdk.server.events.EventConsumer
consumeAndBreakOnInterrupt(EventConsumer, boolean) - Method in class org.a2aproject.sdk.server.tasks.ResultAggregator
consumeAndEmit(EventConsumer) - Method in class org.a2aproject.sdk.server.tasks.ResultAggregator
consumeOne() - Method in class org.a2aproject.sdk.server.events.EventConsumer
consumer(TubeConfiguration, Flow.Publisher<T>, Function<T, Boolean>, Consumer<Throwable>) - Static method in class org.a2aproject.sdk.server.util.async.AsyncUtils
consumptionFuture() - Method in record class org.a2aproject.sdk.server.tasks.ResultAggregator.EventTypeAndInterrupt: Returns the value of the consumptionFuture record component.
convertingProcessor(Flow.Publisher<T>, Function<T, N>) - Static method in class org.a2aproject.sdk.server.util.async.AsyncUtils
CREATE_TASK_PUSH_NOTIFICATION_CONFIG - Enum constant in enum class org.a2aproject.sdk.server.auth.TaskOperation
createAgentRunnableDoneCallback() - Method in class org.a2aproject.sdk.server.events.EventConsumer
createBaseEventQueueBuilder(String) - Method in class org.a2aproject.sdk.server.events.InMemoryQueueManager
createBaseEventQueueBuilder(String) - Method in interface org.a2aproject.sdk.server.events.QueueManager: Creates a base EventQueueBuilder with standard configuration for this QueueManager.
createOrTap(String) - Method in class org.a2aproject.sdk.server.events.InMemoryQueueManager
createOrTap(String) - Method in interface org.a2aproject.sdk.server.events.QueueManager: Creates a MainQueue if none exists, or taps the existing queue to create a ChildQueue.
createTubeConfig() - Static method in class org.a2aproject.sdk.server.util.async.AsyncUtils
createTubeConfig(int) - Static method in class org.a2aproject.sdk.server.util.async.AsyncUtils

D

deactivateExtension(String) - Method in class org.a2aproject.sdk.server.ServerCallContext
DEFAULT_PAGE_SIZE - Static variable in class org.a2aproject.sdk.server.tasks.BasePushNotificationSender
DEFAULT_QUEUE_SIZE - Static variable in class org.a2aproject.sdk.server.events.EventQueue: Default maximum queue size for event queues.
DefaultRequestHandler - Class in org.a2aproject.sdk.server.requesthandlers: Central request orchestrator that coordinates transport requests with agent execution, task persistence, event routing, and push notifications.
DefaultRequestHandler() - Constructor for class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler: No-args constructor for CDI proxy creation.
DefaultRequestHandler(AgentExecutor, TaskStore, QueueManager, PushNotificationConfigStore, MainEventBusProcessor, Executor, Executor) - Constructor for class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler
DefaultRequestHandler.Builder - Class in org.a2aproject.sdk.server.requesthandlers
DefaultTaskStreamLifecycleHook - Class in org.a2aproject.sdk.server.events: Default no-op implementation of TaskStreamLifecycleHook.
DefaultTaskStreamLifecycleHook() - Constructor for class org.a2aproject.sdk.server.events.DefaultTaskStreamLifecycleHook
DefaultValuesConfigProvider - Class in org.a2aproject.sdk.server.config: Default configuration provider that loads values from META-INF/a2a-defaults.properties files on the classpath.
DefaultValuesConfigProvider() - Constructor for class org.a2aproject.sdk.server.config.DefaultValuesConfigProvider
delete(String) - Method in class org.a2aproject.sdk.server.tasks.InMemoryTaskStore
delete(String) - Method in interface org.a2aproject.sdk.server.tasks.TaskStore: Deletes a task by its ID.
DELETE_TASK_PUSH_NOTIFICATION_CONFIG - Enum constant in enum class org.a2aproject.sdk.server.auth.TaskOperation
deleteInfo(String, String) - Method in class org.a2aproject.sdk.server.tasks.InMemoryPushNotificationConfigStore
deleteInfo(String, String) - Method in interface org.a2aproject.sdk.server.tasks.PushNotificationConfigStore: Deletes a push notification configuration for a task.
dequeueEventItem(int) - Method in class org.a2aproject.sdk.server.events.EventQueue: Dequeues an EventQueueItem from the queue.
doClose() - Method in class org.a2aproject.sdk.server.events.EventQueue: Internal method to close the queue gracefully.
doClose(boolean) - Method in class org.a2aproject.sdk.server.events.EventQueue: Internal method to close the queue with control over immediate shutdown.
done(EnhancedRunnable) - Method in interface org.a2aproject.sdk.server.events.EnhancedRunnable.DoneCallback

E

emitEvent(Event) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Emits a custom Event object to the client.
EnhancedRunnable - Class in org.a2aproject.sdk.server.events
EnhancedRunnable() - Constructor for class org.a2aproject.sdk.server.events.EnhancedRunnable
EnhancedRunnable.DoneCallback - Interface in org.a2aproject.sdk.server.events
enqueueEvent(Event) - Method in class org.a2aproject.sdk.server.events.EventQueue: Enqueues an event for processing.
enqueueEventLocalOnly(Event) - Method in class org.a2aproject.sdk.server.events.EventQueue: Enqueues an event directly to this specific queue only, bypassing the MainEventBus.
enqueueItem(EventQueueItem) - Method in class org.a2aproject.sdk.server.events.EventQueue: Enqueues an event queue item for processing.
enqueueLocalOnly(EventQueueItem) - Method in class org.a2aproject.sdk.server.events.EventQueue: Enqueues an event directly to this specific queue only, bypassing the MainEventBus.
ensureStarted() - Method in class org.a2aproject.sdk.server.events.MainEventBusProcessor: No-op method to force CDI proxy resolution and ensure @PostConstruct has been called.
equals(Object) - Method in record class org.a2aproject.sdk.server.auth.AuthenticatedUser: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.a2aproject.sdk.server.tasks.ResultAggregator.EventTypeAndInterrupt: Indicates whether some other object is "equal to" this one.
EventConsumer - Class in org.a2aproject.sdk.server.events
EventConsumer(EventQueue, Executor) - Constructor for class org.a2aproject.sdk.server.events.EventConsumer
eventConsumerExecutor() - Method in class org.a2aproject.sdk.server.util.async.EventConsumerExecutorProducer
eventConsumerExecutor(Executor) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler.Builder
EventConsumerExecutorProducer - Class in org.a2aproject.sdk.server.util.async: Produces a dedicated executor for EventConsumer polling threads.
EventConsumerExecutorProducer() - Constructor for class org.a2aproject.sdk.server.util.async.EventConsumerExecutorProducer
EventConsumerExecutorProducer.EventConsumerExecutor - Annotation Interface in org.a2aproject.sdk.server.util.async: Qualifier annotation for EventConsumer executor injection.
EventEnqueueHook - Interface in org.a2aproject.sdk.server.events: Hook interface for event queue enqueue operations.
EventQueue - Class in org.a2aproject.sdk.server.events: Abstract base class for event queues that manage task event streaming.
EventQueue() - Constructor for class org.a2aproject.sdk.server.events.EventQueue: Creates an EventQueue with the default queue size.
EventQueue(int) - Constructor for class org.a2aproject.sdk.server.events.EventQueue: Creates an EventQueue with the specified queue size.
EventQueue(EventQueue) - Constructor for class org.a2aproject.sdk.server.events.EventQueue: Creates an EventQueue as a child of the specified parent queue.
EventQueue.EventQueueBuilder - Class in org.a2aproject.sdk.server.events: Builder for creating configured EventQueue instances.
EventQueueBuilder() - Constructor for class org.a2aproject.sdk.server.events.EventQueue.EventQueueBuilder
EventQueueClosedException - Exception in org.a2aproject.sdk.server.events: Exception thrown when attempting to dequeue from a closed and empty event queue.
EventQueueClosedException() - Constructor for exception org.a2aproject.sdk.server.events.EventQueueClosedException
EventQueueFactory - Interface in org.a2aproject.sdk.server.events
EventQueueItem - Interface in org.a2aproject.sdk.server.events: Represents an item that can be enqueued/dequeued in an EventQueue.
eventType() - Method in record class org.a2aproject.sdk.server.tasks.ResultAggregator.EventTypeAndInterrupt: Returns the value of the eventType record component.
EventTypeAndInterrupt(EventKind, boolean, CompletableFuture<Void>) - Constructor for record class org.a2aproject.sdk.server.tasks.ResultAggregator.EventTypeAndInterrupt: Creates an instance of a EventTypeAndInterrupt record class.
execute(RequestContext, AgentEmitter) - Method in interface org.a2aproject.sdk.server.agentexecution.AgentExecutor: Executes the agent's business logic for a message.
EXECUTION_WRAPPER_KEY - Static variable in class org.a2aproject.sdk.server.ServerCallContext: Key for an execution wrapper in the state map.
executor(Executor) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler.Builder
ExtendedAgentCard - Annotation Interface in org.a2aproject.sdk.server
extractTaskId(StreamingEventKind) - Method in class org.a2aproject.sdk.server.tasks.BasePushNotificationSender: Extracts the task ID from a StreamingEventKind event.

F

fail() - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as FAILED.
fail(Message) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as FAILED with an optional message.
fail(A2AError) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Enqueues an A2A error event which will automatically transition the task to FAILED.
findExtensionByUri(AgentCard, String) - Static method in class org.a2aproject.sdk.server.extensions.A2AExtensions
formatJsonAsSSE(String, long) - Static method in class org.a2aproject.sdk.server.util.sse.SseFormatter: Format a pre-serialized JSON string as an SSE event.
formatPayload(StreamingEventKind, Task) - Method in interface org.a2aproject.sdk.server.tasks.PushNotificationPayloadFormatter
formatResponseAsSSE(A2AResponse<?>, long) - Static method in class org.a2aproject.sdk.server.util.sse.SseFormatter: Format an A2A response as an SSE event.

G

get(String) - Method in class org.a2aproject.sdk.server.events.InMemoryQueueManager
get(String) - Method in interface org.a2aproject.sdk.server.events.QueueManager: Retrieves the MainQueue for a task, if it exists.
get(String) - Method in class org.a2aproject.sdk.server.tasks.InMemoryTaskStore
get(String) - Method in interface org.a2aproject.sdk.server.tasks.TaskStore: Retrieves a task by its ID.
GET_TASK - Enum constant in enum class org.a2aproject.sdk.server.auth.TaskOperation
GET_TASK_PUSH_NOTIFICATION_CONFIG - Enum constant in enum class org.a2aproject.sdk.server.auth.TaskOperation
getActivatedExtensions() - Method in class org.a2aproject.sdk.server.ServerCallContext
getActiveChildQueueCount(String) - Method in class org.a2aproject.sdk.server.events.InMemoryQueueManager
getActiveChildQueueCount(String) - Method in interface org.a2aproject.sdk.server.events.QueueManager: Returns the number of active ChildQueues for a task.
getActiveSubscriberCount() - Method in interface org.a2aproject.sdk.server.events.StreamCloseHandle: Returns the number of active ChildQueues (subscribers) for this task.
getAttribute(String) - Method in record class org.a2aproject.sdk.server.auth.AuthenticatedUser
getAttribute(String) - Method in interface org.a2aproject.sdk.server.auth.User
getCacheControl() - Method in class org.a2aproject.sdk.server.AgentCardCacheMetadata: Returns the Cache-Control header value for the Agent Card.
getCallContext() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext: Returns the server call context.
getCleanupCallback(String) - Method in class org.a2aproject.sdk.server.events.InMemoryQueueManager: Get the cleanup callback that removes a queue from the map when it closes.
getConfiguration() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext: Returns the request configuration.
getContextId() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext.Builder
getContextId() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext: Returns the conversation context identifier.
getContextId() - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Returns the context ID for this emitter.
getCurrentResult() - Method in class org.a2aproject.sdk.server.tasks.ResultAggregator
getError() - Method in class org.a2aproject.sdk.server.events.EnhancedRunnable
getError() - Method in exception org.a2aproject.sdk.server.JSONRPCException: Returns the wrapped JSON-RPC error.
getETag() - Method in class org.a2aproject.sdk.server.AgentCardCacheMetadata: Returns the ETag header value for the Agent Card.
getEvent() - Method in interface org.a2aproject.sdk.server.events.EventQueueItem: Gets the event contained in this queue item.
getEventQueueBuilder(String) - Method in class org.a2aproject.sdk.server.events.InMemoryQueueManager
getEventQueueBuilder(String) - Method in interface org.a2aproject.sdk.server.events.QueueManager: Returns an EventQueueBuilder for creating queues with task-specific configuration.
getHttpHeadersMap() - Method in class org.a2aproject.sdk.server.AgentCardCacheMetadata: Populates a map with header names and header values stored in this instance.
getInfo(ListTaskPushNotificationConfigsParams) - Method in class org.a2aproject.sdk.server.tasks.InMemoryPushNotificationConfigStore
getInfo(ListTaskPushNotificationConfigsParams) - Method in interface org.a2aproject.sdk.server.tasks.PushNotificationConfigStore: Retrieves push notification configurations for a task with pagination support.
getLastModified() - Method in class org.a2aproject.sdk.server.AgentCardCacheMetadata: Returns the Last-Modified header value for the Agent Card.
getMessage() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext: Returns the user's message.
getMetadata() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext: Returns the request metadata.
getOptionalValue(String) - Method in interface org.a2aproject.sdk.server.config.A2AConfigProvider: Get an optional configuration value.
getOptionalValue(String) - Method in class org.a2aproject.sdk.server.config.DefaultValuesConfigProvider
getParams() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext.Builder
getProtocolVersion(String, String) - Method in class org.a2aproject.sdk.server.tasks.InMemoryPushNotificationConfigStore
getProtocolVersion(String, String) - Method in interface org.a2aproject.sdk.server.tasks.PushNotificationConfigStore: Gets the protocol version associated with a push notification configuration.
getProtocolVersions(String) - Method in class org.a2aproject.sdk.server.tasks.InMemoryPushNotificationConfigStore
getProtocolVersions(String) - Method in interface org.a2aproject.sdk.server.tasks.PushNotificationConfigStore: Gets all protocol versions for a task's push notification configurations in a single call.
getQueueSize() - Method in class org.a2aproject.sdk.server.events.EventQueue: Returns the configured queue size.
getRelatedTasks() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext: Returns other tasks in the same conversation context.
getRequestedExtensions() - Method in class org.a2aproject.sdk.server.ServerCallContext
getRequestedExtensions(List<String>) - Static method in class org.a2aproject.sdk.server.extensions.A2AExtensions
getRequestedProtocolVersion() - Method in class org.a2aproject.sdk.server.ServerCallContext
getState() - Method in class org.a2aproject.sdk.server.ServerCallContext
getTask() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext.Builder
getTask() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext: Returns the existing task state, if this is a continuation of a conversation.
getTask() - Method in class org.a2aproject.sdk.server.tasks.TaskManager
getTaskId() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext.Builder
getTaskId() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext: Returns the task identifier.
getTaskId() - Method in class org.a2aproject.sdk.server.events.QueueClosedEvent
getTaskId() - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Returns the task ID for this emitter.
getTaskId() - Method in exception org.a2aproject.sdk.server.tasks.TaskStoreException: Returns the task ID associated with this exception.
getTenant() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext: Returns the tenant identifier from the request parameters.
getTransportProtocol() - Method in interface org.a2aproject.sdk.server.TransportMetadata: Returns the transport protocol this endpoint supports.
getUser() - Method in class org.a2aproject.sdk.server.ServerCallContext
getUserInput() - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext: Extracts all text content from the message and joins with the newline delimiter.
getUserInput(String) - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext: Extracts all text content from the message and joins with the specified delimiter.
getUsername() - Method in record class org.a2aproject.sdk.server.auth.AuthenticatedUser
getUsername() - Method in class org.a2aproject.sdk.server.auth.UnauthenticatedUser
getUsername() - Method in interface org.a2aproject.sdk.server.auth.User
getValue(String) - Method in interface org.a2aproject.sdk.server.config.A2AConfigProvider: Get a required configuration value.
getValue(String) - Method in class org.a2aproject.sdk.server.config.DefaultValuesConfigProvider

H

hashCode() - Method in record class org.a2aproject.sdk.server.auth.AuthenticatedUser: Returns a hash code value for this object.
hashCode() - Method in record class org.a2aproject.sdk.server.tasks.ResultAggregator.EventTypeAndInterrupt: Returns a hash code value for this object.
hook(EventEnqueueHook) - Method in class org.a2aproject.sdk.server.events.EventQueue.EventQueueBuilder: Sets the enqueue hook for event replication or logging.

I

init() - Method in class org.a2aproject.sdk.server.util.async.AsyncExecutorProducer
InMemoryPushNotificationConfigStore - Class in org.a2aproject.sdk.server.tasks: In-memory implementation of the PushNotificationConfigStore interface.
InMemoryPushNotificationConfigStore() - Constructor for class org.a2aproject.sdk.server.tasks.InMemoryPushNotificationConfigStore
InMemoryQueueManager - Class in org.a2aproject.sdk.server.events
InMemoryQueueManager() - Constructor for class org.a2aproject.sdk.server.events.InMemoryQueueManager: No-args constructor for CDI proxy creation.
InMemoryQueueManager(EventQueueFactory, TaskStateProvider, MainEventBus) - Constructor for class org.a2aproject.sdk.server.events.InMemoryQueueManager
InMemoryQueueManager(EventQueueFactory, TaskStateProvider, MainEventBus, TaskStreamLifecycleHook) - Constructor for class org.a2aproject.sdk.server.events.InMemoryQueueManager
InMemoryQueueManager(TaskStateProvider, MainEventBus) - Constructor for class org.a2aproject.sdk.server.events.InMemoryQueueManager
InMemoryQueueManager(TaskStateProvider, MainEventBus, TaskStreamLifecycleHook) - Constructor for class org.a2aproject.sdk.server.events.InMemoryQueueManager
InMemoryTaskStore - Class in org.a2aproject.sdk.server.tasks: In-memory implementation of TaskStore and TaskStateProvider.
InMemoryTaskStore() - Constructor for class org.a2aproject.sdk.server.tasks.InMemoryTaskStore
InMemoryTaskStore(TaskAuthorizationProvider) - Constructor for class org.a2aproject.sdk.server.tasks.InMemoryTaskStore: Creates an in-memory task store with optional task-level authorization.
InMemoryTaskStore(Instance<TaskAuthorizationProvider>) - Constructor for class org.a2aproject.sdk.server.tasks.InMemoryTaskStore
insertingProcessor(Flow.Publisher<T>, T...) - Static method in class org.a2aproject.sdk.server.util.async.AsyncUtils: Creates a publisher that first emits the given items, then emits all items from the source publisher.
INSTANCE - Static variable in class org.a2aproject.sdk.server.auth.UnauthenticatedUser
INSTANCE - Static variable in class org.a2aproject.sdk.server.PublicAgentCard.Literal
Internal - Annotation Interface in org.a2aproject.sdk.server.util.async: CDI qualifier for internal async executor beans.
interrupted() - Method in record class org.a2aproject.sdk.server.tasks.ResultAggregator.EventTypeAndInterrupt: Returns the value of the interrupted record component.
invokeDoneCallbacks() - Method in class org.a2aproject.sdk.server.events.EnhancedRunnable
invokeEventConsumerCancelCallback() - Method in class org.a2aproject.sdk.server.ServerCallContext: Invokes the EventConsumer cancel callback if one has been set.
isAuthenticated() - Method in record class org.a2aproject.sdk.server.auth.AuthenticatedUser
isAuthenticated() - Method in class org.a2aproject.sdk.server.auth.UnauthenticatedUser
isAuthenticated() - Method in interface org.a2aproject.sdk.server.auth.User
isAvailable() - Method in interface org.a2aproject.sdk.server.TransportMetadata: Checks if this transport endpoint is currently available/functional.
isAwaitingFinalEvent() - Method in class org.a2aproject.sdk.server.events.EventQueue: Returns whether this queue is awaiting a final event to be delivered.
isClosed() - Method in class org.a2aproject.sdk.server.events.EventQueue: Checks if this queue has been closed.
isExtensionActivated(String) - Method in class org.a2aproject.sdk.server.ServerCallContext
isExtensionRequested(String) - Method in class org.a2aproject.sdk.server.ServerCallContext
isReadAuthorized(TaskAuthorizationProvider, ServerCallContext, String) - Method in interface org.a2aproject.sdk.server.tasks.TaskStore: Checks whether a task is authorized for reading during list operations.
isReplicated() - Method in interface org.a2aproject.sdk.server.events.EventQueueItem: Checks if this item represents a replicated event.
isTaskActive(String) - Method in class org.a2aproject.sdk.server.tasks.InMemoryTaskStore
isTaskActive(String) - Method in interface org.a2aproject.sdk.server.tasks.TaskStateProvider: Determines whether a task is considered active for queue management purposes.
isTaskFinalized(String) - Method in class org.a2aproject.sdk.server.tasks.InMemoryTaskStore
isTaskFinalized(String) - Method in interface org.a2aproject.sdk.server.tasks.TaskStateProvider: Determines whether a task is in a final state, ignoring the grace period.
isTaskRecorded(String) - Method in interface org.a2aproject.sdk.server.auth.TaskAuthorizationProvider: Check whether the given task is already known to this provider.

J

JSONRPCException - Exception in org.a2aproject.sdk.server: Exception wrapper for JSON-RPC protocol errors.
JSONRPCException(A2AError) - Constructor for exception org.a2aproject.sdk.server.JSONRPCException: Creates a JSONRPCException wrapping the specified error.

L

list(ListTasksParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.tasks.InMemoryTaskStore
list(ListTasksParams, ServerCallContext) - Method in interface org.a2aproject.sdk.server.tasks.TaskStore: List tasks with optional filtering and pagination.
LIST_TASK_PUSH_NOTIFICATION_CONFIGS - Enum constant in enum class org.a2aproject.sdk.server.auth.TaskOperation
LIST_TASKS - Enum constant in enum class org.a2aproject.sdk.server.auth.TaskOperation
Literal() - Constructor for class org.a2aproject.sdk.server.PublicAgentCard.Literal

M

mainEventBus(MainEventBus) - Method in class org.a2aproject.sdk.server.events.EventQueue.EventQueueBuilder: Sets the main event bus
MainEventBus - Class in org.a2aproject.sdk.server.events
MainEventBus() - Constructor for class org.a2aproject.sdk.server.events.MainEventBus
mainEventBusProcessor(MainEventBusProcessor) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler.Builder
MainEventBusProcessor - Class in org.a2aproject.sdk.server.events: Background processor for the MainEventBus.
MainEventBusProcessor() - Constructor for class org.a2aproject.sdk.server.events.MainEventBusProcessor: No-arg constructor for CDI proxying.
MainEventBusProcessor(MainEventBus, TaskStore, PushNotificationSender, QueueManager) - Constructor for class org.a2aproject.sdk.server.events.MainEventBusProcessor
MainEventBusProcessorCallback - Interface in org.a2aproject.sdk.server.events: Callback interface for MainEventBusProcessor events.
MainEventBusProcessorInitializer - Class in org.a2aproject.sdk.server.events: Portable CDI initializer for MainEventBusProcessor.
MainEventBusProcessorInitializer() - Constructor for class org.a2aproject.sdk.server.events.MainEventBusProcessorInitializer
markStarted() - Method in class org.a2aproject.sdk.server.events.EnhancedRunnable: Marks this runnable as started, preventing further callback additions.
MESSAGE_SEND - Enum constant in enum class org.a2aproject.sdk.server.auth.TaskOperation
MESSAGE_SEND_STREAM - Enum constant in enum class org.a2aproject.sdk.server.auth.TaskOperation
messageBuilder() - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Creates a Message.Builder pre-populated with agent defaults.

N

newAgentMessage(List<Part<?>>, Map<String, Object>) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Creates a new agent message with the given parts and metadata.
newArtifact(String, List<Part<?>>) - Static method in class org.a2aproject.sdk.server.util.ArtifactUtils: Creates a new Artifact object with empty description.
newArtifact(String, List<Part<?>>, String) - Static method in class org.a2aproject.sdk.server.util.ArtifactUtils: Creates a new Artifact object.
newDataArtifact(String, Object) - Static method in class org.a2aproject.sdk.server.util.ArtifactUtils: Creates a new Artifact object containing only a single DataPart with empty description.
newDataArtifact(String, Object, String) - Static method in class org.a2aproject.sdk.server.util.ArtifactUtils: Creates a new Artifact object containing only a single DataPart.
newTextArtifact(String, String) - Static method in class org.a2aproject.sdk.server.util.ArtifactUtils: Creates a new Artifact object containing only a single TextPart with empty description.
newTextArtifact(String, String, String) - Static method in class org.a2aproject.sdk.server.util.ArtifactUtils: Creates a new Artifact object containing only a single TextPart.
NOOP - Static variable in interface org.a2aproject.sdk.server.events.MainEventBusProcessorCallback: No-op implementation that does nothing.
NoTaskQueueException - Exception in org.a2aproject.sdk.server.events: Exception thrown when attempting to access a task queue that does not exist.
NoTaskQueueException() - Constructor for exception org.a2aproject.sdk.server.events.NoTaskQueueException: Creates a NoTaskQueueException with no message.
NoTaskQueueException(String) - Constructor for exception org.a2aproject.sdk.server.events.NoTaskQueueException: Creates a NoTaskQueueException with the specified detail message.
NoTaskQueueException(String, Throwable) - Constructor for exception org.a2aproject.sdk.server.events.NoTaskQueueException: Creates a NoTaskQueueException with the specified detail message and cause.
NoTaskQueueException(String, Throwable, boolean, boolean) - Constructor for exception org.a2aproject.sdk.server.events.NoTaskQueueException: Creates a NoTaskQueueException with the specified message, cause, suppression enabled or disabled, and writable stack trace enabled or disabled.
NoTaskQueueException(Throwable) - Constructor for exception org.a2aproject.sdk.server.events.NoTaskQueueException: Creates a NoTaskQueueException with the specified cause.

O

onCancelTask(CancelTaskParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.AuthorizationRequestHandlerDecorator
onCancelTask(CancelTaskParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler
onCancelTask(CancelTaskParams, ServerCallContext) - Method in interface org.a2aproject.sdk.server.requesthandlers.RequestHandler
onCreateTaskPushNotificationConfig(TaskPushNotificationConfig, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.AuthorizationRequestHandlerDecorator
onCreateTaskPushNotificationConfig(TaskPushNotificationConfig, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler
onCreateTaskPushNotificationConfig(TaskPushNotificationConfig, ServerCallContext) - Method in interface org.a2aproject.sdk.server.requesthandlers.RequestHandler
onDeleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.AuthorizationRequestHandlerDecorator
onDeleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler
onDeleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigParams, ServerCallContext) - Method in interface org.a2aproject.sdk.server.requesthandlers.RequestHandler
onEnqueue(EventQueueItem) - Method in interface org.a2aproject.sdk.server.events.EventEnqueueHook: Called when an item is enqueued to the event queue.
onEvent(String, Event, StreamCloseHandle) - Method in class org.a2aproject.sdk.server.events.DefaultTaskStreamLifecycleHook
onEvent(String, Event, StreamCloseHandle) - Method in interface org.a2aproject.sdk.server.events.TaskStreamLifecycleHook: Called after an event has been persisted and distributed to all ChildQueues.
onEventProcessed(String, Event) - Method in interface org.a2aproject.sdk.server.events.MainEventBusProcessorCallback: Called after an event has been fully processed (persisted, notification sent, distributed to children).
onGetTask(TaskQueryParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.AuthorizationRequestHandlerDecorator
onGetTask(TaskQueryParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler
onGetTask(TaskQueryParams, ServerCallContext) - Method in interface org.a2aproject.sdk.server.requesthandlers.RequestHandler
onGetTaskPushNotificationConfig(GetTaskPushNotificationConfigParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.AuthorizationRequestHandlerDecorator
onGetTaskPushNotificationConfig(GetTaskPushNotificationConfigParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler
onGetTaskPushNotificationConfig(GetTaskPushNotificationConfigParams, ServerCallContext) - Method in interface org.a2aproject.sdk.server.requesthandlers.RequestHandler
onListTaskPushNotificationConfigs(ListTaskPushNotificationConfigsParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.AuthorizationRequestHandlerDecorator
onListTaskPushNotificationConfigs(ListTaskPushNotificationConfigsParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler
onListTaskPushNotificationConfigs(ListTaskPushNotificationConfigsParams, ServerCallContext) - Method in interface org.a2aproject.sdk.server.requesthandlers.RequestHandler
onListTasks(ListTasksParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.AuthorizationRequestHandlerDecorator
onListTasks(ListTasksParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler
onListTasks(ListTasksParams, ServerCallContext) - Method in interface org.a2aproject.sdk.server.requesthandlers.RequestHandler
onMessageSend(MessageSendParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.AuthorizationRequestHandlerDecorator
onMessageSend(MessageSendParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler
onMessageSend(MessageSendParams, ServerCallContext) - Method in interface org.a2aproject.sdk.server.requesthandlers.RequestHandler
onMessageSendStream(MessageSendParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.AuthorizationRequestHandlerDecorator
onMessageSendStream(MessageSendParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler
onMessageSendStream(MessageSendParams, ServerCallContext) - Method in interface org.a2aproject.sdk.server.requesthandlers.RequestHandler
onSubscribe(String, StreamCloseHandle) - Method in class org.a2aproject.sdk.server.events.DefaultTaskStreamLifecycleHook
onSubscribe(String, StreamCloseHandle) - Method in interface org.a2aproject.sdk.server.events.TaskStreamLifecycleHook: Called when a new ChildQueue is created for a task (a client subscribes to the stream).
onSubscribeToTask(TaskIdParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.AuthorizationRequestHandlerDecorator
onSubscribeToTask(TaskIdParams, ServerCallContext) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler
onSubscribeToTask(TaskIdParams, ServerCallContext) - Method in interface org.a2aproject.sdk.server.requesthandlers.RequestHandler
onTaskFinalized(String) - Method in interface org.a2aproject.sdk.server.events.MainEventBusProcessorCallback: Called when a task reaches a final state (COMPLETED, FAILED, CANCELED, REJECTED).
onUnsubscribe(String, StreamCloseHandle) - Method in class org.a2aproject.sdk.server.events.DefaultTaskStreamLifecycleHook
onUnsubscribe(String, StreamCloseHandle) - Method in interface org.a2aproject.sdk.server.events.TaskStreamLifecycleHook: Called when a ChildQueue closes for a task (a client disconnects or streams are closed).
org.a2aproject.sdk.server - package org.a2aproject.sdk.server
org.a2aproject.sdk.server.agentexecution - package org.a2aproject.sdk.server.agentexecution
org.a2aproject.sdk.server.auth - package org.a2aproject.sdk.server.auth
org.a2aproject.sdk.server.config - package org.a2aproject.sdk.server.config
org.a2aproject.sdk.server.events - package org.a2aproject.sdk.server.events
org.a2aproject.sdk.server.extensions - package org.a2aproject.sdk.server.extensions
org.a2aproject.sdk.server.requesthandlers - package org.a2aproject.sdk.server.requesthandlers
org.a2aproject.sdk.server.tasks - package org.a2aproject.sdk.server.tasks
org.a2aproject.sdk.server.util - package org.a2aproject.sdk.server.util
org.a2aproject.sdk.server.util.async - package org.a2aproject.sdk.server.util.async
org.a2aproject.sdk.server.util.sse - package org.a2aproject.sdk.server.util.sse: Server-Sent Events (SSE) formatting utilities for A2A streaming responses.
org.a2aproject.sdk.server.version - package org.a2aproject.sdk.server.version

P

populateReferredTasks(boolean) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler.Builder
process(Event, boolean) - Method in class org.a2aproject.sdk.server.tasks.TaskManager
process(Event, boolean, AtomicReference<Task>) - Method in class org.a2aproject.sdk.server.tasks.TaskManager
processor(TubeConfiguration, Flow.Publisher<T>, BiFunction<Consumer<Throwable>, T, Boolean>) - Static method in class org.a2aproject.sdk.server.util.async.AsyncUtils
produce() - Method in class org.a2aproject.sdk.server.util.async.AsyncExecutorProducer
PublicAgentCard - Annotation Interface in org.a2aproject.sdk.server
PublicAgentCard.Literal - Class in org.a2aproject.sdk.server
pushConfigStore(PushNotificationConfigStore) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler.Builder
PushNotificationConfigStore - Interface in org.a2aproject.sdk.server.tasks: Interface for storing and retrieving push notification configurations for tasks.
PushNotificationPayloadFormatter - Interface in org.a2aproject.sdk.server.tasks
PushNotificationSender - Interface in org.a2aproject.sdk.server.tasks: Interface for delivering push notifications containing task state updates to external systems.

Q

QueueClosedEvent - Class in org.a2aproject.sdk.server.events: Poison pill event used to signal that a queue has been closed.
QueueClosedEvent(String) - Constructor for class org.a2aproject.sdk.server.events.QueueClosedEvent
queueManager(QueueManager) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler.Builder
QueueManager - Interface in org.a2aproject.sdk.server.events: Manages EventQueue lifecycle for task-based event routing and consumption.
queueSize(int) - Method in class org.a2aproject.sdk.server.events.EventQueue.EventQueueBuilder: Sets the maximum queue size.

R

recordOwnership(ServerCallContext, String, TaskOperation) - Method in interface org.a2aproject.sdk.server.auth.TaskAuthorizationProvider: Record that the current user owns the given task.
reject() - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as REJECTED.
reject(Message) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as REJECTED with an optional message.
RequestContext - Class in org.a2aproject.sdk.server.agentexecution: Container for request parameters and task state provided to AgentExecutor.
RequestContext.Builder - Class in org.a2aproject.sdk.server.agentexecution: Builder for creating RequestContext instances.
RequestHandler - Interface in org.a2aproject.sdk.server.requesthandlers
requiresAuth() - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as AUTH_REQUIRED, indicating the agent needs authentication to continue.
requiresAuth(boolean) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Deprecated, for removal: This API element is subject to removal in a future version.
The isFinal parameter has no effect. Use AgentEmitter.requiresAuth() instead.
requiresAuth(Message) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as AUTH_REQUIRED with an optional message.
requiresAuth(Message, boolean) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Deprecated, for removal: This API element is subject to removal in a future version.
The isFinal parameter has no effect. Use AgentEmitter.requiresAuth(Message) instead.
requiresInput() - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as INPUT_REQUIRED, indicating the agent needs user input to continue.
requiresInput(boolean) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Deprecated, for removal: This API element is subject to removal in a future version.
The isFinal parameter has no effect. Use AgentEmitter.requiresInput() instead.
requiresInput(Message) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as INPUT_REQUIRED with an optional message.
requiresInput(Message, boolean) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Deprecated, for removal: This API element is subject to removal in a future version.
The isFinal parameter has no effect. Use AgentEmitter.requiresInput(Message) instead.
resolveProtocolVersion(String) - Static method in interface org.a2aproject.sdk.server.tasks.PushNotificationConfigStore: Resolves the protocol version, defaulting null to the current protocol version.
ResultAggregator - Class in org.a2aproject.sdk.server.tasks
ResultAggregator(TaskManager, Message, Executor, Executor, long) - Constructor for class org.a2aproject.sdk.server.tasks.ResultAggregator
ResultAggregator.EventTypeAndInterrupt - Record Class in org.a2aproject.sdk.server.tasks
run() - Method in class org.a2aproject.sdk.server.events.MainEventBusProcessor

S

save(Task, boolean) - Method in class org.a2aproject.sdk.server.tasks.InMemoryTaskStore
save(Task, boolean) - Method in interface org.a2aproject.sdk.server.tasks.TaskStore: Saves or updates a task.
sendMessage(String) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Sends a simple text message to the client.
sendMessage(List<Part<?>>) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Sends a message with custom parts (text, images, etc.) to the client.
sendMessage(List<Part<?>>, Map<String, Object>) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Sends a message with parts and metadata to the client.
sendMessage(Message) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Sends an existing Message object directly to the client.
sendNotification(StreamingEventKind, Task) - Method in class org.a2aproject.sdk.server.tasks.BasePushNotificationSender
sendNotification(StreamingEventKind, Task) - Method in interface org.a2aproject.sdk.server.tasks.PushNotificationSender: Sends a push notification containing a streaming event.
ServerCallContext - Class in org.a2aproject.sdk.server
ServerCallContext(User, Map<String, Object>, Set<String>) - Constructor for class org.a2aproject.sdk.server.ServerCallContext
ServerCallContext(User, Map<String, Object>, Set<String>, String) - Constructor for class org.a2aproject.sdk.server.ServerCallContext
setCallback(MainEventBusProcessorCallback) - Method in class org.a2aproject.sdk.server.events.MainEventBusProcessor: Set a callback for testing synchronization with async event processing.
setContextId(String) - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext.Builder
setError(Throwable) - Method in class org.a2aproject.sdk.server.events.EnhancedRunnable
setEventConsumerCancelCallback(Runnable) - Method in class org.a2aproject.sdk.server.ServerCallContext: Sets the callback to be invoked when the client disconnects or the call is cancelled.
setInfo(TaskPushNotificationConfig) - Method in class org.a2aproject.sdk.server.tasks.InMemoryPushNotificationConfigStore
setInfo(TaskPushNotificationConfig) - Method in interface org.a2aproject.sdk.server.tasks.PushNotificationConfigStore: Sets or updates the push notification configuration for a task.
setInfo(TaskPushNotificationConfig, String) - Method in class org.a2aproject.sdk.server.tasks.InMemoryPushNotificationConfigStore
setInfo(TaskPushNotificationConfig, String) - Method in interface org.a2aproject.sdk.server.tasks.PushNotificationConfigStore: Sets or updates the push notification configuration for a task, along with the protocol version that registered it.
setParams(MessageSendParams) - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext.Builder
setPushNotificationExecutor(Executor) - Method in class org.a2aproject.sdk.server.events.MainEventBusProcessor: Set a custom executor for push notifications (primarily for testing).
setRelatedTasks(List<Task>) - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext.Builder
setServerCallContext(ServerCallContext) - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext.Builder
setTask(Task) - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext.Builder
setTaskId(String) - Method in class org.a2aproject.sdk.server.agentexecution.RequestContext.Builder
signalQueuePollerStarted() - Method in class org.a2aproject.sdk.server.events.EventQueue: Signals that the queue poller has started consuming events.
SimpleRequestContextBuilder - Class in org.a2aproject.sdk.server.agentexecution
SimpleRequestContextBuilder(TaskStore, boolean, TaskAuthorizationProvider) - Constructor for class org.a2aproject.sdk.server.agentexecution.SimpleRequestContextBuilder
size() - Method in class org.a2aproject.sdk.server.events.EventQueue: Returns the current size of the queue.
size() - Method in class org.a2aproject.sdk.server.events.MainEventBus
SKIP_GRPC_PROPERTY - Static variable in class org.a2aproject.sdk.server.AgentCardValidator
SKIP_JSONRPC_PROPERTY - Static variable in class org.a2aproject.sdk.server.AgentCardValidator
SKIP_PROPERTY - Static variable in class org.a2aproject.sdk.server.AgentCardValidator
SKIP_REST_PROPERTY - Static variable in class org.a2aproject.sdk.server.AgentCardValidator
SseFormatter - Class in org.a2aproject.sdk.server.util.sse: Framework-agnostic utility for formatting A2A responses as Server-Sent Events (SSE).
startWork() - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as WORKING (actively being processed).
startWork(Message) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as WORKING with an optional message.
StreamCloseHandle - Interface in org.a2aproject.sdk.server.events: Handle for closing all active streams (ChildQueues) for a task.
streamLifecycleHook(TaskStreamLifecycleHook) - Method in class org.a2aproject.sdk.server.events.EventQueue.EventQueueBuilder: Sets the stream lifecycle hook for subscribe/unsubscribe/event notifications.
STRICT_CONTEXT_VALIDATION_KEY - Static variable in class org.a2aproject.sdk.server.ServerCallContext: Key for context ID validation mode in the state map.
submit() - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as SUBMITTED.
submit(Message) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Marks the task as SUBMITTED with an optional message.
SUBSCRIBE_TO_TASK - Enum constant in enum class org.a2aproject.sdk.server.auth.TaskOperation

T

tap() - Method in class org.a2aproject.sdk.server.events.EventQueue: Creates a child queue that shares events with this queue.
tap(String) - Method in class org.a2aproject.sdk.server.events.InMemoryQueueManager
tap(String) - Method in interface org.a2aproject.sdk.server.events.QueueManager: Creates a ChildQueue that receives copies of events from the MainQueue.
targetVersion() - Method in interface org.a2aproject.sdk.server.tasks.PushNotificationPayloadFormatter
TaskAuthorizationProvider - Interface in org.a2aproject.sdk.server.auth: SPI for per-user task authorization.
taskBuilder() - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Creates a Task.Builder pre-populated with the correct task and context IDs.
taskDone() - Method in class org.a2aproject.sdk.server.events.EventQueue: Placeholder method for task completion notification.
taskId(String) - Method in class org.a2aproject.sdk.server.events.EventQueue.EventQueueBuilder: Associates this queue with a specific task ID.
TaskManager - Class in org.a2aproject.sdk.server.tasks
TaskManager(String, String, TaskStore, Message) - Constructor for class org.a2aproject.sdk.server.tasks.TaskManager
TaskOperation - Enum Class in org.a2aproject.sdk.server.auth: Identifies which RequestHandler operation triggered an authorization check.
TaskPersistenceException - Exception in org.a2aproject.sdk.server.tasks: Exception for database/storage system failures during task persistence operations.
TaskPersistenceException() - Constructor for exception org.a2aproject.sdk.server.tasks.TaskPersistenceException: Creates a new TaskPersistenceException with no message or cause.
TaskPersistenceException(String, String) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskPersistenceException: Creates a new TaskPersistenceException with the specified task ID and message.
TaskPersistenceException(String, String, Throwable) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskPersistenceException: Creates a new TaskPersistenceException with the specified task ID, message, and cause.
TaskPersistenceException(String) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskPersistenceException: Creates a new TaskPersistenceException with the specified message.
TaskPersistenceException(String, Throwable) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskPersistenceException: Creates a new TaskPersistenceException with the specified message and cause.
TaskPersistenceException(Throwable) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskPersistenceException: Creates a new TaskPersistenceException with the specified cause.
TaskQueueExistsException - Exception in org.a2aproject.sdk.server.events
TaskQueueExistsException() - Constructor for exception org.a2aproject.sdk.server.events.TaskQueueExistsException
TaskQueueExistsException(String) - Constructor for exception org.a2aproject.sdk.server.events.TaskQueueExistsException
TaskQueueExistsException(String, Throwable) - Constructor for exception org.a2aproject.sdk.server.events.TaskQueueExistsException
TaskQueueExistsException(String, Throwable, boolean, boolean) - Constructor for exception org.a2aproject.sdk.server.events.TaskQueueExistsException
TaskQueueExistsException(Throwable) - Constructor for exception org.a2aproject.sdk.server.events.TaskQueueExistsException
TaskSerializationException - Exception in org.a2aproject.sdk.server.tasks: Exception for task serialization/deserialization failures.
TaskSerializationException() - Constructor for exception org.a2aproject.sdk.server.tasks.TaskSerializationException: Creates a new TaskSerializationException with no message or cause.
TaskSerializationException(String, String) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskSerializationException: Creates a new TaskSerializationException with the specified task ID and message.
TaskSerializationException(String, String, Throwable) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskSerializationException: Creates a new TaskSerializationException with the specified task ID, message, and cause.
TaskSerializationException(String) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskSerializationException: Creates a new TaskSerializationException with the specified message.
TaskSerializationException(String, Throwable) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskSerializationException: Creates a new TaskSerializationException with the specified message and cause.
TaskSerializationException(Throwable) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskSerializationException: Creates a new TaskSerializationException with the specified cause.
taskStateProvider(TaskStateProvider) - Method in class org.a2aproject.sdk.server.events.EventQueue.EventQueueBuilder: Sets the task state provider for tracking task finalization.
TaskStateProvider - Interface in org.a2aproject.sdk.server.tasks: Provider interface for determining the active state of a task.
taskStore(TaskStore) - Method in class org.a2aproject.sdk.server.requesthandlers.DefaultRequestHandler.Builder
TaskStore - Interface in org.a2aproject.sdk.server.tasks: Storage interface for managing task persistence across the task lifecycle.
TaskStoreException - Exception in org.a2aproject.sdk.server.tasks: Base exception for TaskStore persistence layer failures.
TaskStoreException() - Constructor for exception org.a2aproject.sdk.server.tasks.TaskStoreException: Creates a new TaskStoreException with no message or cause.
TaskStoreException(String, String) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskStoreException: Creates a new TaskStoreException with the specified task ID and message.
TaskStoreException(String, String, Throwable) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskStoreException: Creates a new TaskStoreException with the specified task ID, message, and cause.
TaskStoreException(String) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskStoreException: Creates a new TaskStoreException with the specified message.
TaskStoreException(String, Throwable) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskStoreException: Creates a new TaskStoreException with the specified message and cause.
TaskStoreException(Throwable) - Constructor for exception org.a2aproject.sdk.server.tasks.TaskStoreException: Creates a new TaskStoreException with the specified cause.
TaskStreamLifecycleHook - Interface in org.a2aproject.sdk.server.events: Hook for observing task stream lifecycle events and controlling stream resources.
toString() - Method in record class org.a2aproject.sdk.server.auth.AuthenticatedUser: Returns a string representation of this record class.
toString() - Method in class org.a2aproject.sdk.server.events.QueueClosedEvent
toString() - Method in record class org.a2aproject.sdk.server.tasks.ResultAggregator.EventTypeAndInterrupt: Returns a string representation of this record class.
TRANSPORT_KEY - Static variable in class org.a2aproject.sdk.server.ServerCallContext: Key for transport protocol type in the state map.
TransportMetadata - Interface in org.a2aproject.sdk.server: Interface for transport endpoint implementations to provide metadata about their transport.

U

UnauthenticatedUser - Class in org.a2aproject.sdk.server.auth
updateStatus(TaskState, Message) - Method in class org.a2aproject.sdk.server.tasks.AgentEmitter: Updates the task status to the given state with an optional message.
updateWithMessage(Message, Task) - Method in class org.a2aproject.sdk.server.tasks.TaskManager
User - Interface in org.a2aproject.sdk.server.auth
username() - Method in record class org.a2aproject.sdk.server.auth.AuthenticatedUser: Returns the value of the username record component.

V

validateProtocolVersion(AgentCard, ServerCallContext) - Static method in class org.a2aproject.sdk.server.version.A2AVersionValidator: Validates that the client's requested protocol version is compatible with the agent's supported versions across all interfaces.
validateRequiredExtensions(AgentCard, ServerCallContext) - Static method in class org.a2aproject.sdk.server.extensions.A2AExtensions: Validates that all required extensions declared in the AgentCard are requested by the client.
validateTransportConfiguration(AgentCard) - Static method in class org.a2aproject.sdk.server.AgentCardValidator: Validates the transport configuration of an AgentCard against available transports found on the classpath.
valueOf(String) - Static method in enum class org.a2aproject.sdk.server.auth.TaskOperation: Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.a2aproject.sdk.server.auth.TaskOperation: Returns an array containing the constants of this enum class, in the order they are declared.

A B C D E F G H I J L M N O P Q R S T U V
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form