Index (Java SDK A2A Core 1.0.0.Alpha2 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 io.a2a.server.config: Configuration provider interface for A2A SDK configuration values.
A2AExtensions - Class in io.a2a.server.extensions
A2AExtensions() - Constructor for class io.a2a.server.extensions.A2AExtensions
A2AVersionValidator - Class in io.a2a.server.version: Utility class for validating A2A protocol version compatibility between clients and agents.
A2AVersionValidator() - Constructor for class io.a2a.server.version.A2AVersionValidator
activateExtension(String) - Method in class io.a2a.server.ServerCallContext
add(String, EventQueue) - Method in class io.a2a.server.events.InMemoryQueueManager
add(String, EventQueue) - Method in interface io.a2a.server.events.QueueManager: Adds a queue to the manager with the given task ID.
addArtifact(List<Part<?>>) - Method in class io.a2a.server.tasks.AgentEmitter: Adds an artifact with the given parts to the task.
addArtifact(List<Part<?>>, String, String, Map<String, Object>) - Method in class io.a2a.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 io.a2a.server.tasks.AgentEmitter: Adds an artifact with all optional parameters.
addDoneCallback(EnhancedRunnable.DoneCallback) - Method in class io.a2a.server.events.EnhancedRunnable
addOnCloseCallback(Runnable) - Method in class io.a2a.server.events.EventQueue.EventQueueBuilder: Adds a callback to be executed when the queue is closed.
addTask(Task) - Method in class io.a2a.server.tasks.AgentEmitter: Adds a custom Task object to be sent to the client.
AgentCardValidator - Class in io.a2a.server: Validates AgentCard transport configuration against available transport endpoints.
AgentCardValidator() - Constructor for class io.a2a.server.AgentCardValidator
AgentEmitter - Class in io.a2a.server.tasks: Helper for emitting events from AgentExecutor implementations.
AgentEmitter(RequestContext, EventQueue) - Constructor for class io.a2a.server.tasks.AgentEmitter: Creates a new AgentEmitter for the given request context and event queue.
AgentExecutor - Interface in io.a2a.server.agentexecution: Core business logic interface for implementing A2A agent functionality.
ArtifactUtils - Class in io.a2a.server.util: Utility functions for creating A2A Artifact objects.
AsyncExecutorProducer - Class in io.a2a.server.util.async
AsyncExecutorProducer() - Constructor for class io.a2a.server.util.async.AsyncExecutorProducer
AsyncUtils - Class in io.a2a.server.util.async
AsyncUtils() - Constructor for class io.a2a.server.util.async.AsyncUtils
attachRelatedTask(Task) - Method in class io.a2a.server.agentexecution.RequestContext: Attaches a related task to this context.
awaitQueuePollerStart() - Method in class io.a2a.server.events.EventQueue: Waits for the queue poller to start consuming events.
awaitQueuePollerStart(EventQueue) - Method in class io.a2a.server.events.InMemoryQueueManager
awaitQueuePollerStart(EventQueue) - Method in interface io.a2a.server.events.QueueManager: Waits for the queue's consumer polling to start.

B

BasePushNotificationSender - Class in io.a2a.server.tasks
BasePushNotificationSender() - Constructor for class io.a2a.server.tasks.BasePushNotificationSender: No-args constructor for CDI proxy creation.
BasePushNotificationSender(PushNotificationConfigStore) - Constructor for class io.a2a.server.tasks.BasePushNotificationSender
BasePushNotificationSender(PushNotificationConfigStore, A2AHttpClient) - Constructor for class io.a2a.server.tasks.BasePushNotificationSender
build() - Method in class io.a2a.server.agentexecution.RequestContext.Builder: Builds the RequestContext with ID generation and validation.
build() - Method in class io.a2a.server.agentexecution.SimpleRequestContextBuilder
build() - Method in class io.a2a.server.events.EventQueue.EventQueueBuilder: Builds and returns the configured EventQueue.
builder(String) - Method in interface io.a2a.server.events.EventQueueFactory: Creates an EventQueueBuilder with the specified taskId context.
Builder() - Constructor for class io.a2a.server.agentexecution.RequestContext.Builder

C

cancel() - Method in class io.a2a.server.events.EventConsumer
cancel() - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as CANCELED.
cancel(Message) - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as CANCELED with an optional message.
cancel(RequestContext, AgentEmitter) - Method in interface io.a2a.server.agentexecution.AgentExecutor: Cancels an ongoing agent execution.
close() - Method in class io.a2a.server.events.EventConsumer
close() - Method in class io.a2a.server.events.EventQueue: Closes this event queue gracefully, allowing pending events to be consumed.
close() - Method in class io.a2a.server.util.async.AsyncExecutorProducer
close(boolean) - Method in class io.a2a.server.events.EventQueue: Closes this event queue with control over immediate shutdown.
close(boolean, boolean) - Method in class io.a2a.server.events.EventQueue: Close this queue with control over parent notification (ChildQueue only).
close(String) - Method in class io.a2a.server.events.InMemoryQueueManager
close(String) - Method in interface io.a2a.server.events.QueueManager: Closes and removes the queue for a task.
complete() - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as COMPLETED.
complete(Message) - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as COMPLETED with an optional message.
consumeAll() - Method in class io.a2a.server.events.EventConsumer
consumeAll(EventConsumer) - Method in class io.a2a.server.tasks.ResultAggregator
consumeAndBreakOnInterrupt(EventConsumer, boolean) - Method in class io.a2a.server.tasks.ResultAggregator
consumeAndEmit(EventConsumer) - Method in class io.a2a.server.tasks.ResultAggregator
consumeOne() - Method in class io.a2a.server.events.EventConsumer
consumer(TubeConfiguration, Flow.Publisher<T>, Function<T, Boolean>, Consumer<Throwable>) - Static method in class io.a2a.server.util.async.AsyncUtils
consumptionFuture() - Method in record class io.a2a.server.tasks.ResultAggregator.EventTypeAndInterrupt: Returns the value of the consumptionFuture record component.
convertingProcessor(Flow.Publisher<T>, Function<T, N>) - Static method in class io.a2a.server.util.async.AsyncUtils
create(AgentExecutor, TaskStore, QueueManager, PushNotificationConfigStore, MainEventBusProcessor, Executor, Executor) - Static method in class io.a2a.server.requesthandlers.DefaultRequestHandler: For testing
createAgentRunnableDoneCallback() - Method in class io.a2a.server.events.EventConsumer
createBaseEventQueueBuilder(String) - Method in class io.a2a.server.events.InMemoryQueueManager
createBaseEventQueueBuilder(String) - Method in interface io.a2a.server.events.QueueManager: Creates a base EventQueueBuilder with standard configuration for this QueueManager.
createOrTap(String) - Method in class io.a2a.server.events.InMemoryQueueManager
createOrTap(String) - Method in interface io.a2a.server.events.QueueManager: Creates a MainQueue if none exists, or taps the existing queue to create a ChildQueue.
createTubeConfig() - Static method in class io.a2a.server.util.async.AsyncUtils
createTubeConfig(int) - Static method in class io.a2a.server.util.async.AsyncUtils

D

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

E

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

F

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

G

get(String) - Method in class io.a2a.server.events.InMemoryQueueManager
get(String) - Method in interface io.a2a.server.events.QueueManager: Retrieves the MainQueue for a task, if it exists.
get(String) - Method in class io.a2a.server.tasks.InMemoryTaskStore
get(String) - Method in interface io.a2a.server.tasks.TaskStore: Retrieves a task by its ID.
getActivatedExtensions() - Method in class io.a2a.server.ServerCallContext
getActiveChildQueueCount(String) - Method in class io.a2a.server.events.InMemoryQueueManager
getActiveChildQueueCount(String) - Method in interface io.a2a.server.events.QueueManager: Returns the number of active ChildQueues for a task.
getCallContext() - Method in class io.a2a.server.agentexecution.RequestContext: Returns the server call context.
getCleanupCallback(String) - Method in class io.a2a.server.events.InMemoryQueueManager: Get the cleanup callback that removes a queue from the map when it closes.
getConfiguration() - Method in class io.a2a.server.agentexecution.RequestContext: Returns the request configuration.
getContextId() - Method in class io.a2a.server.agentexecution.RequestContext.Builder
getContextId() - Method in class io.a2a.server.agentexecution.RequestContext: Returns the conversation context identifier.
getContextId() - Method in class io.a2a.server.tasks.AgentEmitter: Returns the context ID for this emitter.
getCurrentResult() - Method in class io.a2a.server.tasks.ResultAggregator
getError() - Method in class io.a2a.server.events.EnhancedRunnable
getError() - Method in exception io.a2a.server.JSONRPCException: Returns the wrapped JSON-RPC error.
getEvent() - Method in interface io.a2a.server.events.EventQueueItem: Gets the event contained in this queue item.
getEventQueueBuilder(String) - Method in class io.a2a.server.events.InMemoryQueueManager
getEventQueueBuilder(String) - Method in interface io.a2a.server.events.QueueManager: Returns an EventQueueBuilder for creating queues with task-specific configuration.
getInfo(ListTaskPushNotificationConfigParams) - Method in class io.a2a.server.tasks.InMemoryPushNotificationConfigStore
getInfo(ListTaskPushNotificationConfigParams) - Method in interface io.a2a.server.tasks.PushNotificationConfigStore: Retrieves push notification configurations for a task with pagination support.
getMessage() - Method in class io.a2a.server.agentexecution.RequestContext: Returns the user's message.
getOptionalValue(String) - Method in interface io.a2a.server.config.A2AConfigProvider: Get an optional configuration value.
getOptionalValue(String) - Method in class io.a2a.server.config.DefaultValuesConfigProvider
getParams() - Method in class io.a2a.server.agentexecution.RequestContext.Builder
getQueueSize() - Method in class io.a2a.server.events.EventQueue: Returns the configured queue size.
getRelatedTasks() - Method in class io.a2a.server.agentexecution.RequestContext.Builder
getRelatedTasks() - Method in class io.a2a.server.agentexecution.RequestContext: Returns other tasks in the same conversation context.
getRequestedExtensions() - Method in class io.a2a.server.ServerCallContext
getRequestedExtensions(List<String>) - Static method in class io.a2a.server.extensions.A2AExtensions
getRequestedProtocolVersion() - Method in class io.a2a.server.ServerCallContext
getServerCallContext() - Method in class io.a2a.server.agentexecution.RequestContext.Builder
getState() - Method in class io.a2a.server.ServerCallContext
getTask() - Method in class io.a2a.server.agentexecution.RequestContext.Builder
getTask() - Method in class io.a2a.server.agentexecution.RequestContext: Returns the existing task state, if this is a continuation of a conversation.
getTask() - Method in class io.a2a.server.tasks.TaskManager
getTaskId() - Method in class io.a2a.server.agentexecution.RequestContext.Builder
getTaskId() - Method in class io.a2a.server.agentexecution.RequestContext: Returns the task identifier.
getTaskId() - Method in class io.a2a.server.events.QueueClosedEvent
getTaskId() - Method in class io.a2a.server.tasks.AgentEmitter: Returns the task ID for this emitter.
getTenant() - Method in class io.a2a.server.agentexecution.RequestContext: Returns the tenant identifier from the request parameters.
getTransportProtocol() - Method in interface io.a2a.server.TransportMetadata: Returns the transport protocol this endpoint supports.
getUser() - Method in class io.a2a.server.ServerCallContext
getUserInput(String) - Method in class io.a2a.server.agentexecution.RequestContext: Extracts all text content from the message and joins with the specified delimiter.
getUsername() - Method in class io.a2a.server.auth.UnauthenticatedUser
getUsername() - Method in interface io.a2a.server.auth.User
getValue(String) - Method in interface io.a2a.server.config.A2AConfigProvider: Get a required configuration value.
getValue(String) - Method in class io.a2a.server.config.DefaultValuesConfigProvider

H

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

I

init() - Method in class io.a2a.server.util.async.AsyncExecutorProducer
InMemoryPushNotificationConfigStore - Class in io.a2a.server.tasks: In-memory implementation of the PushNotificationConfigStore interface.
InMemoryPushNotificationConfigStore() - Constructor for class io.a2a.server.tasks.InMemoryPushNotificationConfigStore
InMemoryQueueManager - Class in io.a2a.server.events
InMemoryQueueManager() - Constructor for class io.a2a.server.events.InMemoryQueueManager: No-args constructor for CDI proxy creation.
InMemoryQueueManager(EventQueueFactory, TaskStateProvider, MainEventBus) - Constructor for class io.a2a.server.events.InMemoryQueueManager
InMemoryQueueManager(TaskStateProvider, MainEventBus) - Constructor for class io.a2a.server.events.InMemoryQueueManager
InMemoryTaskStore - Class in io.a2a.server.tasks: In-memory implementation of TaskStore and TaskStateProvider.
InMemoryTaskStore() - Constructor for class io.a2a.server.tasks.InMemoryTaskStore
INSTANCE - Static variable in class io.a2a.server.auth.UnauthenticatedUser
Internal - Annotation Interface in io.a2a.server.util.async: CDI qualifier for internal async executor beans.
interrupted() - Method in record class io.a2a.server.tasks.ResultAggregator.EventTypeAndInterrupt: Returns the value of the interrupted record component.
invokeDoneCallbacks() - Method in class io.a2a.server.events.EnhancedRunnable
invokeEventConsumerCancelCallback() - Method in class io.a2a.server.ServerCallContext: Invokes the EventConsumer cancel callback if one has been set.
io.a2a.server - package io.a2a.server
io.a2a.server.agentexecution - package io.a2a.server.agentexecution
io.a2a.server.auth - package io.a2a.server.auth
io.a2a.server.config - package io.a2a.server.config
io.a2a.server.events - package io.a2a.server.events
io.a2a.server.extensions - package io.a2a.server.extensions
io.a2a.server.requesthandlers - package io.a2a.server.requesthandlers
io.a2a.server.tasks - package io.a2a.server.tasks
io.a2a.server.util - package io.a2a.server.util
io.a2a.server.util.async - package io.a2a.server.util.async
io.a2a.server.util.sse - package io.a2a.server.util.sse: Server-Sent Events (SSE) formatting utilities for A2A streaming responses.
io.a2a.server.version - package io.a2a.server.version
isAuthenticated() - Method in class io.a2a.server.auth.UnauthenticatedUser
isAuthenticated() - Method in interface io.a2a.server.auth.User
isAvailable() - Method in interface io.a2a.server.TransportMetadata: Checks if this transport endpoint is currently available/functional.
isClosed() - Method in class io.a2a.server.events.EventQueue: Checks if this queue has been closed.
isExtensionActivated(String) - Method in class io.a2a.server.ServerCallContext
isExtensionRequested(String) - Method in class io.a2a.server.ServerCallContext
isReplicated() - Method in interface io.a2a.server.events.EventQueueItem: Checks if this item represents a replicated event.
isTaskActive(String) - Method in class io.a2a.server.tasks.InMemoryTaskStore
isTaskActive(String) - Method in interface io.a2a.server.tasks.TaskStateProvider: Determines whether a task is considered active for queue management purposes.
isTaskFinalized(String) - Method in class io.a2a.server.tasks.InMemoryTaskStore
isTaskFinalized(String) - Method in interface io.a2a.server.tasks.TaskStateProvider: Determines whether a task is in a final state, ignoring the grace period.

J

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

L

list(ListTasksParams) - Method in class io.a2a.server.tasks.InMemoryTaskStore
list(ListTasksParams) - Method in interface io.a2a.server.tasks.TaskStore: List tasks with optional filtering and pagination.
logPoolStats() - Method in class io.a2a.server.util.async.AsyncExecutorProducer: Log current executor pool statistics for diagnostics.

M

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

N

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

O

onCancelTask(TaskIdParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler
onCancelTask(TaskIdParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler
onCreateTaskPushNotificationConfig(TaskPushNotificationConfig, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler
onCreateTaskPushNotificationConfig(TaskPushNotificationConfig, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler
onDeleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler
onDeleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler
onEnqueue(EventQueueItem) - Method in interface io.a2a.server.events.EventEnqueueHook: Called when an item is enqueued to the event queue.
onEventProcessed(String, Event) - Method in interface io.a2a.server.events.MainEventBusProcessorCallback: Called after an event has been fully processed (persisted, notification sent, distributed to children).
onGetTask(TaskQueryParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler
onGetTask(TaskQueryParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler
onGetTaskPushNotificationConfig(GetTaskPushNotificationConfigParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler
onGetTaskPushNotificationConfig(GetTaskPushNotificationConfigParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler
onListTaskPushNotificationConfig(ListTaskPushNotificationConfigParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler
onListTaskPushNotificationConfig(ListTaskPushNotificationConfigParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler
onListTasks(ListTasksParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler
onListTasks(ListTasksParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler
onMessageSend(MessageSendParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler
onMessageSend(MessageSendParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler
onMessageSendStream(MessageSendParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler
onMessageSendStream(MessageSendParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler
onSubscribeToTask(TaskIdParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler
onSubscribeToTask(TaskIdParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler
onTaskFinalized(String) - Method in interface io.a2a.server.events.MainEventBusProcessorCallback: Called when a task reaches a final state (COMPLETED, FAILED, CANCELED, REJECTED).

P

process(Event, boolean) - Method in class io.a2a.server.tasks.TaskManager
processor(TubeConfiguration, Flow.Publisher<T>, BiFunction<Consumer<Throwable>, T, Boolean>) - Static method in class io.a2a.server.util.async.AsyncUtils
produce() - Method in class io.a2a.server.util.async.AsyncExecutorProducer
PublicAgentCard - Annotation Interface in io.a2a.server
PushNotificationConfigStore - Interface in io.a2a.server.tasks: Interface for storing and retrieving push notification configurations for tasks.
PushNotificationSender - Interface in io.a2a.server.tasks: Interface for delivering push notifications containing task state updates to external systems.

Q

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

R

reject() - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as REJECTED.
reject(Message) - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as REJECTED with an optional message.
RequestContext - Class in io.a2a.server.agentexecution: Container for request parameters and task state provided to AgentExecutor.
RequestContext.Builder - Class in io.a2a.server.agentexecution: Builder for creating RequestContext instances.
RequestHandler - Interface in io.a2a.server.requesthandlers
requiresAuth() - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as AUTH_REQUIRED, indicating the agent needs authentication to continue.
requiresAuth(boolean) - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as AUTH_REQUIRED with a finality flag.
requiresAuth(Message) - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as AUTH_REQUIRED with an optional message.
requiresAuth(Message, boolean) - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as AUTH_REQUIRED with an optional message and finality flag.
requiresInput() - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as INPUT_REQUIRED, indicating the agent needs user input to continue.
requiresInput(boolean) - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as INPUT_REQUIRED with a finality flag.
requiresInput(Message) - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as INPUT_REQUIRED with an optional message.
requiresInput(Message, boolean) - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as INPUT_REQUIRED with an optional message and finality flag.
ResultAggregator - Class in io.a2a.server.tasks
ResultAggregator(TaskManager, Message, Executor, Executor) - Constructor for class io.a2a.server.tasks.ResultAggregator
ResultAggregator.EventTypeAndInterrupt - Record Class in io.a2a.server.tasks
run() - Method in class io.a2a.server.events.MainEventBusProcessor

S

save(Task, boolean) - Method in class io.a2a.server.tasks.InMemoryTaskStore
save(Task, boolean) - Method in interface io.a2a.server.tasks.TaskStore: Saves or updates a task.
sendMessage(Message) - Method in class io.a2a.server.tasks.AgentEmitter: Sends an existing Message object directly to the client.
sendMessage(String) - Method in class io.a2a.server.tasks.AgentEmitter: Sends a simple text message to the client.
sendMessage(List<Part<?>>) - Method in class io.a2a.server.tasks.AgentEmitter: Sends a message with custom parts (text, images, etc.) to the client.
sendMessage(List<Part<?>>, Map<String, Object>) - Method in class io.a2a.server.tasks.AgentEmitter: Sends a message with parts and metadata to the client.
sendNotification(StreamingEventKind) - Method in class io.a2a.server.tasks.BasePushNotificationSender
sendNotification(StreamingEventKind) - Method in interface io.a2a.server.tasks.PushNotificationSender: Sends a push notification containing a streaming event.
ServerCallContext - Class in io.a2a.server
ServerCallContext(User, Map<String, Object>, Set<String>) - Constructor for class io.a2a.server.ServerCallContext
ServerCallContext(User, Map<String, Object>, Set<String>, String) - Constructor for class io.a2a.server.ServerCallContext
setCallback(MainEventBusProcessorCallback) - Method in class io.a2a.server.events.MainEventBusProcessor: Set a callback for testing synchronization with async event processing.
setContextId(String) - Method in class io.a2a.server.agentexecution.RequestContext.Builder
setError(Throwable) - Method in class io.a2a.server.events.EnhancedRunnable
setEventConsumerCancelCallback(Runnable) - Method in class io.a2a.server.ServerCallContext: Sets the callback to be invoked when the client disconnects or the call is cancelled.
setInfo(String, PushNotificationConfig) - Method in class io.a2a.server.tasks.InMemoryPushNotificationConfigStore
setInfo(String, PushNotificationConfig) - Method in interface io.a2a.server.tasks.PushNotificationConfigStore: Sets or updates the push notification configuration for a task.
setParams(MessageSendParams) - Method in class io.a2a.server.agentexecution.RequestContext.Builder
setPushNotificationExecutor(Executor) - Method in class io.a2a.server.events.MainEventBusProcessor: Set a custom executor for push notifications (primarily for testing).
setRelatedTasks(List<Task>) - Method in class io.a2a.server.agentexecution.RequestContext.Builder
setServerCallContext(ServerCallContext) - Method in class io.a2a.server.agentexecution.RequestContext.Builder
setTask(Task) - Method in class io.a2a.server.agentexecution.RequestContext.Builder
setTaskId(String) - Method in class io.a2a.server.agentexecution.RequestContext.Builder
signalQueuePollerStarted() - Method in class io.a2a.server.events.EventQueue: Signals that the queue poller has started consuming events.
SimpleRequestContextBuilder - Class in io.a2a.server.agentexecution
SimpleRequestContextBuilder(TaskStore, boolean) - Constructor for class io.a2a.server.agentexecution.SimpleRequestContextBuilder
size() - Method in class io.a2a.server.events.EventQueue: Returns the current size of the queue.
size() - Method in class io.a2a.server.events.MainEventBus
SKIP_GRPC_PROPERTY - Static variable in class io.a2a.server.AgentCardValidator
SKIP_JSONRPC_PROPERTY - Static variable in class io.a2a.server.AgentCardValidator
SKIP_PROPERTY - Static variable in class io.a2a.server.AgentCardValidator
SKIP_REST_PROPERTY - Static variable in class io.a2a.server.AgentCardValidator
SseFormatter - Class in io.a2a.server.util.sse: Framework-agnostic utility for formatting A2A responses as Server-Sent Events (SSE).
startWork() - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as WORKING (actively being processed).
startWork(Message) - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as WORKING with an optional message.
submit() - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as SUBMITTED.
submit(Message) - Method in class io.a2a.server.tasks.AgentEmitter: Marks the task as SUBMITTED with an optional message.

T

tap() - Method in class io.a2a.server.events.EventQueue: Creates a child queue that shares events with this queue.
tap(String) - Method in class io.a2a.server.events.InMemoryQueueManager
tap(String) - Method in interface io.a2a.server.events.QueueManager: Creates a ChildQueue that receives copies of events from the MainQueue.
taskBuilder() - Method in class io.a2a.server.tasks.AgentEmitter: Creates a Task.Builder pre-populated with the correct task and context IDs.
taskDone() - Method in class io.a2a.server.events.EventQueue: Placeholder method for task completion notification.
taskId(String) - Method in class io.a2a.server.events.EventQueue.EventQueueBuilder: Associates this queue with a specific task ID.
TaskManager - Class in io.a2a.server.tasks
TaskManager(String, String, TaskStore, Message) - Constructor for class io.a2a.server.tasks.TaskManager
TaskQueueExistsException - Exception in io.a2a.server.events
TaskQueueExistsException() - Constructor for exception io.a2a.server.events.TaskQueueExistsException
TaskQueueExistsException(String) - Constructor for exception io.a2a.server.events.TaskQueueExistsException
TaskQueueExistsException(String, Throwable) - Constructor for exception io.a2a.server.events.TaskQueueExistsException
TaskQueueExistsException(String, Throwable, boolean, boolean) - Constructor for exception io.a2a.server.events.TaskQueueExistsException
TaskQueueExistsException(Throwable) - Constructor for exception io.a2a.server.events.TaskQueueExistsException
taskStateProvider(TaskStateProvider) - Method in class io.a2a.server.events.EventQueue.EventQueueBuilder: Sets the task state provider for tracking task finalization.
TaskStateProvider - Interface in io.a2a.server.tasks: Provider interface for determining the active state of a task.
TaskStore - Interface in io.a2a.server.tasks: Storage interface for managing task persistence across the task lifecycle.
toString() - Method in class io.a2a.server.events.QueueClosedEvent
toString() - Method in record class io.a2a.server.tasks.ResultAggregator.EventTypeAndInterrupt: Returns a string representation of this record class.
TransportMetadata - Interface in io.a2a.server: Interface for transport endpoint implementations to provide metadata about their transport.

U

UnauthenticatedUser - Class in io.a2a.server.auth
updateStatus(TaskState, Message) - Method in class io.a2a.server.tasks.AgentEmitter: Updates the task status to the given state with an optional message.
updateWithMessage(Message, Task) - Method in class io.a2a.server.tasks.TaskManager
User - Interface in io.a2a.server.auth

V

validateProtocolVersion(AgentCard, ServerCallContext) - Static method in class io.a2a.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 io.a2a.server.extensions.A2AExtensions: Validates that all required extensions declared in the AgentCard are requested by the client.
validateTransportConfiguration(AgentCard) - Static method in class io.a2a.server.AgentCardValidator: Validates the transport configuration of an AgentCard against available transports found on the classpath.

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