Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- A2AClient - Class in com.mulesoft.connectors.a2a.internal.client.connection
- A2AClient(String, int, HttpClient, HttpRequestAuthentication, MultiMap<String, String>, A2ASerializer) - Constructor for class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
- A2AConnector - Class in com.mulesoft.connectors.a2a.internal.extension
-
Allows Mule applications to act as both A2A servers and clients
- A2AConnector() - Constructor for class com.mulesoft.connectors.a2a.internal.extension.A2AConnector
- A2AErrorTypes - Enum Class in com.mulesoft.connectors.a2a.internal.error
-
Represents an error that can happen in an A2A operation.
- A2ASerializer - Class in com.mulesoft.connectors.a2a.internal.protocol
- A2ASerializer() - Constructor for class com.mulesoft.connectors.a2a.internal.protocol.A2ASerializer
- a2aService(A2ASerializer) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- A2AUtils - Class in com.mulesoft.connectors.a2a.internal.util
- AcceptedPushNotificationConfigParameterGroup - Class in com.mulesoft.connectors.a2a.internal.server.listener.push.model
- AcceptedPushNotificationConfigParameterGroup() - Constructor for class com.mulesoft.connectors.a2a.internal.server.listener.push.model.AcceptedPushNotificationConfigParameterGroup
- addBufferedEvent(TaskEvent) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.StreamingContext
- additionalHeaders(MultiMap<String, String>) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig.Builder
- addPushNotificationConfig(EffectivePushNotificationConfig) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- addTracingData(RpcRequestContext, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- agentCard(AgentCard) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- AgentCardDiscoveryException - Exception in com.mulesoft.connectors.a2a.internal.error.exception
-
Base exception for agent card discovery failures.
- AgentCardDiscoveryException(String, URI, Throwable) - Constructor for exception com.mulesoft.connectors.a2a.internal.error.exception.AgentCardDiscoveryException
- AgentCardDiscoveryException.HttpErrorException - Exception in com.mulesoft.connectors.a2a.internal.error.exception
-
Exception thrown when the agent card endpoint returns a non-200 HTTP status code.
- AgentCardDiscoveryException.InvalidAgentCardException - Exception in com.mulesoft.connectors.a2a.internal.error.exception
-
Exception thrown when the agent card JSON cannot be parsed or is invalid.
- AgentCardDiscoveryException.NotFoundException - Exception in com.mulesoft.connectors.a2a.internal.error.exception
-
Exception thrown when the agent card endpoint is not found (404).
- AgentCardErrorTypeProvider - Class in com.mulesoft.connectors.a2a.internal.error.provider
- AgentCardErrorTypeProvider() - Constructor for class com.mulesoft.connectors.a2a.internal.error.provider.AgentCardErrorTypeProvider
- AgentCardHelper - Class in com.mulesoft.connectors.a2a.internal.client.helper
-
Helper class for agent card parsing and validation.
- AgentCardHelper() - Constructor for class com.mulesoft.connectors.a2a.internal.client.helper.AgentCardHelper
- AgentCardParameterGroup - Class in com.mulesoft.connectors.a2a.internal.server
- AgentCardParameterGroup() - Constructor for class com.mulesoft.connectors.a2a.internal.server.AgentCardParameterGroup
- AlternativeNameData - Class in com.mulesoft.connectors.a2a.api.certificate
-
A custom Data Transfer Object (DTO) to replace the
X509CertificateAlternativeName class. - AlternativeNameData(int, String) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.AlternativeNameData
-
Constructs a new
AlternativeNameDatainstance with the specified type and name. - apply(String, CheckedRunnable) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskRepository
- apply(String, CheckedRunnable) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.NullTaskRepository
- apply(String, CheckedRunnable) - Method in interface com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepository
-
Applies a function to a task within a transactional context, ensuring thread-safe access to the task data.
- ARTIFACT_UPDATE_EVENT - Static variable in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseConstants
-
SSE event type for task artifact updates.
- authentication(HttpRequestAuthentication) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig.Builder
B
- BaseServerListener<T,
A> - Class in com.mulesoft.connectors.a2a.internal.server.listener - BaseServerListener() - Constructor for class com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener
- BasicOperationErrorTypeProvider - Class in com.mulesoft.connectors.a2a.internal.error.provider
-
Returns the common error types that most likely apply to any component
- BasicOperationErrorTypeProvider() - Constructor for class com.mulesoft.connectors.a2a.internal.error.provider.BasicOperationErrorTypeProvider
- body(InputStream) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext.Response.Builder
- broadcastEvent(String, String, StreamingEventKind, TaskRepository, A2ASerializer, SseClientRegistry) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.SseUtils
-
Broadcasts an SSE event to all clients for a specific task
- build() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig.Builder
- build() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- build() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext.Response.Builder
- buildCertificateData(ClientConnection) - Static method in class com.mulesoft.connectors.a2a.internal.util.certificate.CertificateUtils
- builder() - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- builder() - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext.Response
- Builder() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig.Builder
- buildRequestAttributes(String, String, HttpRequestContext) - Static method in class com.mulesoft.connectors.a2a.internal.util.certificate.HttpUtils
C
- cancelTask(A2AClient, InputStream, RequestParameterGroup, DistributedTraceContextManager, CompletionCallback<String, ResponseAttributes>) - Method in class com.mulesoft.connectors.a2a.internal.client.operation.ClientOperations
- cancelTask(InputStream, RequestParameterGroup, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
- CancelTaskRequestHandler - Class in com.mulesoft.connectors.a2a.internal.server.agent.operations
- CancelTaskRequestHandler() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.operations.CancelTaskRequestHandler
- CertificateData - Class in com.mulesoft.connectors.a2a.api.certificate
-
A custom Data Transfer Object (DTO) to replace
Certificate,X509Certificate, and related classes. - CertificateData(String, byte[]) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Constructs a new
CertificateDatainstance with the specified type and encoded form. - CertificateData(String, byte[], int, PrincipalData, PrincipalData, BigInteger, Date, Date, PublicKeyData, String, String, byte[], byte[], int, List<String>, boolean[], boolean[], List<AlternativeNameData>, List<AlternativeNameData>, List<CertificateExtension>, Set<String>, Set<String>, boolean) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Constructs a new
CertificateDatainstance with detailed attributes. - CertificateExtension - Class in com.mulesoft.connectors.a2a.api.certificate
-
A custom Data Transfer Object (DTO) to replace the certificate extension class from the
X509Extensionpackage. - CertificateExtension(String, boolean, byte[], String) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.CertificateExtension
-
Constructs a new
CertificateExtensioninstance with the specified attributes. - CertificateUtils - Class in com.mulesoft.connectors.a2a.internal.util.certificate
- CertificateUtils() - Constructor for class com.mulesoft.connectors.a2a.internal.util.certificate.CertificateUtils
- checkValidity() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Checks if the certificate is currently valid.
- checkValidity(Date) - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Checks if the certificate is valid at the specified date.
- clearPushNotificationConfigs() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- clearPushNotificationConfigs(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskStoreServiceImpl
- clearPushNotificationConfigs(String) - Method in interface com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskStoreService
- ClientCertificateAware - Class in com.mulesoft.connectors.a2a.api.certificate
-
Base class for entities that contain information about a client certificate.
- ClientCertificateAware() - Constructor for class com.mulesoft.connectors.a2a.api.certificate.ClientCertificateAware
- ClientCertificateAware(Supplier<CertificateData>) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.ClientCertificateAware
- ClientConfig - Class in com.mulesoft.connectors.a2a.internal.client.config
- ClientConfig() - Constructor for class com.mulesoft.connectors.a2a.internal.client.config.ClientConfig
- ClientConnectionProvider - Class in com.mulesoft.connectors.a2a.internal.client.connection.provider
-
A client connection to an A2A server
- ClientConnectionProvider() - Constructor for class com.mulesoft.connectors.a2a.internal.client.connection.provider.ClientConnectionProvider
- ClientException - Exception in com.mulesoft.connectors.a2a.internal.error.exception
-
Exception that carries the complete response details (body and attributes) when A2A client operations fail.
- ClientException(String, A2AErrorTypes) - Constructor for exception com.mulesoft.connectors.a2a.internal.error.exception.ClientException
-
Constructor for client-side errors without server response
- ClientException(String, A2AErrorTypes, String, ResponseAttributes) - Constructor for exception com.mulesoft.connectors.a2a.internal.error.exception.ClientException
- ClientOperations - Class in com.mulesoft.connectors.a2a.internal.client.operation
- ClientOperations() - Constructor for class com.mulesoft.connectors.a2a.internal.client.operation.ClientOperations
- close() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskRepository
- close() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.NullTaskRepository
- close() - Method in interface com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepository
- close() - Method in class com.mulesoft.connectors.a2a.internal.util.ObjectStoreAccessor
- closeAllConnections(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseClientRegistry
-
Closes all SSE connections for a specific task and removes the task from registry.
- closeSingleConnection(String, SseClient) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseClientRegistry
-
Closes a single SSE connection and removes it from the registry.
- com.mulesoft.connectors.a2a.api.certificate - package com.mulesoft.connectors.a2a.api.certificate
- com.mulesoft.connectors.a2a.api.listener - package com.mulesoft.connectors.a2a.api.listener
- com.mulesoft.connectors.a2a.api.model.transport - package com.mulesoft.connectors.a2a.api.model.transport
- com.mulesoft.connectors.a2a.internal.client.config - package com.mulesoft.connectors.a2a.internal.client.config
- com.mulesoft.connectors.a2a.internal.client.connection - package com.mulesoft.connectors.a2a.internal.client.connection
- com.mulesoft.connectors.a2a.internal.client.connection.provider - package com.mulesoft.connectors.a2a.internal.client.connection.provider
- com.mulesoft.connectors.a2a.internal.client.helper - package com.mulesoft.connectors.a2a.internal.client.helper
- com.mulesoft.connectors.a2a.internal.client.model - package com.mulesoft.connectors.a2a.internal.client.model
- com.mulesoft.connectors.a2a.internal.client.operation - package com.mulesoft.connectors.a2a.internal.client.operation
- com.mulesoft.connectors.a2a.internal.client.route - package com.mulesoft.connectors.a2a.internal.client.route
- com.mulesoft.connectors.a2a.internal.datasense - package com.mulesoft.connectors.a2a.internal.datasense
- com.mulesoft.connectors.a2a.internal.error - package com.mulesoft.connectors.a2a.internal.error
- com.mulesoft.connectors.a2a.internal.error.exception - package com.mulesoft.connectors.a2a.internal.error.exception
- com.mulesoft.connectors.a2a.internal.error.provider - package com.mulesoft.connectors.a2a.internal.error.provider
- com.mulesoft.connectors.a2a.internal.extension - package com.mulesoft.connectors.a2a.internal.extension
- com.mulesoft.connectors.a2a.internal.protocol - package com.mulesoft.connectors.a2a.internal.protocol
- com.mulesoft.connectors.a2a.internal.server - package com.mulesoft.connectors.a2a.internal.server
- com.mulesoft.connectors.a2a.internal.server.agent - package com.mulesoft.connectors.a2a.internal.server.agent
- com.mulesoft.connectors.a2a.internal.server.agent.model - package com.mulesoft.connectors.a2a.internal.server.agent.model
- com.mulesoft.connectors.a2a.internal.server.agent.operations - package com.mulesoft.connectors.a2a.internal.server.agent.operations
- com.mulesoft.connectors.a2a.internal.server.agent.push - package com.mulesoft.connectors.a2a.internal.server.agent.push
- com.mulesoft.connectors.a2a.internal.server.agent.repository - package com.mulesoft.connectors.a2a.internal.server.agent.repository
- com.mulesoft.connectors.a2a.internal.server.agent.sse - package com.mulesoft.connectors.a2a.internal.server.agent.sse
- com.mulesoft.connectors.a2a.internal.server.agent.utils - package com.mulesoft.connectors.a2a.internal.server.agent.utils
- com.mulesoft.connectors.a2a.internal.server.connection.http - package com.mulesoft.connectors.a2a.internal.server.connection.http
- com.mulesoft.connectors.a2a.internal.server.listener - package com.mulesoft.connectors.a2a.internal.server.listener
- com.mulesoft.connectors.a2a.internal.server.listener.push - package com.mulesoft.connectors.a2a.internal.server.listener.push
- com.mulesoft.connectors.a2a.internal.server.listener.push.model - package com.mulesoft.connectors.a2a.internal.server.listener.push.model
- com.mulesoft.connectors.a2a.internal.server.listener.task - package com.mulesoft.connectors.a2a.internal.server.listener.task
- com.mulesoft.connectors.a2a.internal.server.listener.task.model - package com.mulesoft.connectors.a2a.internal.server.listener.task.model
- com.mulesoft.connectors.a2a.internal.server.operation - package com.mulesoft.connectors.a2a.internal.server.operation
- com.mulesoft.connectors.a2a.internal.server.operations - package com.mulesoft.connectors.a2a.internal.server.operations
- com.mulesoft.connectors.a2a.internal.tracing - package com.mulesoft.connectors.a2a.internal.tracing
- com.mulesoft.connectors.a2a.internal.util - package com.mulesoft.connectors.a2a.internal.util
- com.mulesoft.connectors.a2a.internal.util.certificate - package com.mulesoft.connectors.a2a.internal.util.certificate
- componentLocation - Variable in class com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener
- config - Variable in class com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener
- connect() - Method in class com.mulesoft.connectors.a2a.internal.client.connection.provider.ClientConnectionProvider
- connect() - Method in class com.mulesoft.connectors.a2a.internal.server.connection.http.HttpServerConnectionProvider
- connectionProvider - Variable in class com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener
- ContextRepositoryItem - Class in com.mulesoft.connectors.a2a.internal.server.agent.repository
- ContextRepositoryItem(String) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.repository.ContextRepositoryItem
- copy(MultiMap<String, String>) - Static method in class com.mulesoft.connectors.a2a.internal.util.A2AUtils
-
Creates an immutable copy of a MultiMap.
- create(String, String, StreamingContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskStoreServiceImpl
-
Create new entry for provided taskId and contextId in object store along with StreamingContext
- create(String, String, StreamingContext) - Method in interface com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskStoreService
- createEffectivePushNotificationConfig(RpcRequestContext) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig
-
Creates an EffectivePushNotificationConfig synchronously from the request context.
- createFromHttpResponse(HttpResponse) - Static method in class com.mulesoft.connectors.a2a.internal.client.helper.ResponseAttributesHelper
-
Creates ResponseAttributes from an HTTP response.
- createResponseBody(RequestHandlerContext, RpcRequestContext.Response) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.CancelTaskRequestHandler
- createResponseBody(RequestHandlerContext, RpcRequestContext.Response) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.DeletePushNotificationConfigHandler
- createResponseBody(RequestHandlerContext, RpcRequestContext.Response) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.GetPushNotificationConfigHandler
- createResponseBody(RequestHandlerContext, RpcRequestContext.Response) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.GetRequestHandler
- createResponseBody(RequestHandlerContext, RpcRequestContext.Response) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.ListPushNotificationConfigHandler
- createResponseBody(RequestHandlerContext, RpcRequestContext.Response) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.MessageStreamHandler
- createResponseBody(RequestHandlerContext, RpcRequestContext.Response) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.RequestHandler
- createResponseBody(RequestHandlerContext, RpcRequestContext.Response) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.SendMessageHandler
- createResponseBody(RequestHandlerContext, RpcRequestContext.Response) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.SetPushNotificationConfigHandler
- createResponseBody(RequestHandlerContext, RpcRequestContext.Response) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.TaskResubscribeHandler
- createSseConnection(RequestHandlerContext, String) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.SseUtils
-
Creates SSE connection and registers it
- createStreamingFromResponseAttributes(ResponseAttributes, Boolean) - Static method in class com.mulesoft.connectors.a2a.internal.client.helper.ResponseAttributesHelper
-
Creates StreamingResponseAttributes from existing ResponseAttributes with final event information.
- createStreamingResponse(String, StreamingEventKind, TaskRepository) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.SseUtils
-
Creates a JSON-RPC success response for SSE events
- CrossWorkerPoller - Class in com.mulesoft.connectors.a2a.internal.server.agent.sse
-
Cross-worker poller for SSE event delivery.
- CrossWorkerPoller(String, SseClient, TaskRepository, A2ASerializer, SseClientRegistry, Scheduler) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.sse.CrossWorkerPoller
- customizeSpan() - Method in class com.mulesoft.connectors.a2a.internal.tracing.InboundSpanCustomizer
- customizeSpan() - Method in class com.mulesoft.connectors.a2a.internal.tracing.OutboundSpanCustomizer
- customizeSpan() - Method in class com.mulesoft.connectors.a2a.internal.tracing.SpanCustomizer
-
Customize the current span
D
- DataSenseUtils - Class in com.mulesoft.connectors.a2a.internal.datasense
-
Utility class for DataSense operations.
- DEFAULT_TIME_UNIT - Static variable in class com.mulesoft.connectors.a2a.internal.server.listener.push.model.AcceptedPushNotificationConfigParameterGroup
- DEFAULT_TIMEOUT - Static variable in class com.mulesoft.connectors.a2a.internal.server.listener.push.model.AcceptedPushNotificationConfigParameterGroup
- DefaultTaskRepository - Class in com.mulesoft.connectors.a2a.internal.server.agent.repository
-
Default implementation of TaskRepository that manages task data and push notification configs.
- DefaultTaskRepository(ObjectStore<RepositoryItem>, LockFactory, String) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskRepository
- DefaultTaskStoreServiceImpl - Class in com.mulesoft.connectors.a2a.internal.server.agent.repository
- DefaultTaskStoreServiceImpl(TaskRepository, A2ASerializer) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskStoreServiceImpl
- deletePushNotificationConfig(A2AClient, InputStream, RequestParameterGroup, DistributedTraceContextManager, CompletionCallback<String, ResponseAttributes>) - Method in class com.mulesoft.connectors.a2a.internal.client.operation.ClientOperations
- deletePushNotificationConfig(InputStream, RequestParameterGroup, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
-
Delete push notification config from the agent via "tasks/pushNotificationConfig/delete" operation.
- DeletePushNotificationConfigHandler - Class in com.mulesoft.connectors.a2a.internal.server.agent.operations
- DeletePushNotificationConfigHandler() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.operations.DeletePushNotificationConfigHandler
- deletePushNotificationConfigs(RequestHandlerContext, TaskRepositoryItem, String, String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.DeletePushNotificationConfigHandler
- deletePushNotificationConfigs(String, String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskStoreServiceImpl
- deletePushNotificationConfigs(String, String) - Method in interface com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskStoreService
- disconnect(A2AClient) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.provider.ClientConnectionProvider
- disconnect(ServerAgent) - Method in class com.mulesoft.connectors.a2a.internal.server.connection.http.HttpServerConnectionProvider
- dispose() - Method in class com.mulesoft.connectors.a2a.internal.client.connection.provider.ClientConnectionProvider
- dispose() - Method in class com.mulesoft.connectors.a2a.internal.server.connection.http.HttpServerConnectionProvider
- doExecute(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.CancelTaskRequestHandler
- doExecute(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.DeletePushNotificationConfigHandler
- doExecute(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.GetPushNotificationConfigHandler
- doExecute(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.GetRequestHandler
- doExecute(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.ListPushNotificationConfigHandler
- doExecute(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.MessageStreamHandler
- doExecute(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.RequestHandler
- doExecute(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.SendMessageHandler
- doExecute(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.SetPushNotificationConfigHandler
- doExecute(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.TaskResubscribeHandler
- doInitialise() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener
- doInitialise() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.push.PushNotificationConfigListener
- doInitialise() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.TaskListener
- doInitialise() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.TaskStreamListener
E
- EffectivePushNotificationConfig - Class in com.mulesoft.connectors.a2a.internal.server.agent.push
- EffectivePushNotificationConfig() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig
- EffectivePushNotificationConfig(EffectivePushNotificationConfig.Builder) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig
- EffectivePushNotificationConfig.Builder - Class in com.mulesoft.connectors.a2a.internal.server.agent.push
- equals(Object) - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
- equals(Object) - Method in class com.mulesoft.connectors.a2a.api.certificate.PrincipalData
- equals(Object) - Method in class com.mulesoft.connectors.a2a.api.certificate.X500PrincipalData
- equals(Object) - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
- equals(Object) - Method in class com.mulesoft.connectors.a2a.api.model.transport.ResponseAttributes
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in class com.mulesoft.connectors.a2a.api.model.transport.StreamingResponseAttributes
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.mulesoft.connectors.a2a.internal.client.model.SseConnectionResult
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.mulesoft.connectors.a2a.internal.client.model.SseSessionResult
-
Indicates whether some other object is "equal to" this one.
- error(JSONRPCError) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext.Response.Builder
- ERROR_STATUS - Static variable in class com.mulesoft.connectors.a2a.internal.tracing.TracingUtils
- ErrorUtils - Class in com.mulesoft.connectors.a2a.internal.error
-
Utility class for handling error types in the A2A connector.
- events() - Method in record class com.mulesoft.connectors.a2a.internal.client.model.SseSessionResult
-
Returns the value of the
eventsrecord component. - execute(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.RequestHandler
F
- finalEventFound() - Method in record class com.mulesoft.connectors.a2a.internal.client.model.SseSessionResult
-
Returns the value of the
finalEventFoundrecord component. - formatHexAndAscii(byte[]) - Static method in class com.mulesoft.connectors.a2a.api.certificate.CertificateExtension
-
Formats the given byte array into a hex and ASCII string representation.
- formatSignature(byte[]) - Static method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Formats the signature bytes into a readable string representation.
- fromRpcErrorCode(Integer) - Static method in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
G
- get(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskRepository
- get(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.NullTaskRepository
- get(String) - Method in interface com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepository
- get(String) - Method in class com.mulesoft.connectors.a2a.internal.util.ObjectStoreAccessor
- getA2AErrorType(Throwable) - Static method in class com.mulesoft.connectors.a2a.internal.error.ErrorUtils
-
Retrieves the
A2AErrorTypesfrom a givenThrowable, if present. - getA2ASerializer() - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
- getA2aService() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getA2aService() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- getAdditionalHeaders() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig
- getAdditionalHeaders() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.push.model.AcceptedPushNotificationConfigParameterGroup
- getAdditionalProperties() - Method in class com.mulesoft.connectors.a2a.api.model.transport.RequestParameterGroup
-
Returns the additional properties provided by the user as key-value pairs.
- getAgentCard() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getAgentCard(boolean, boolean, RequestParameterGroup, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
-
Fetches the agent card and returns it as an AgentCard object.
- getAgentCardConfig() - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- getAlgorithm() - Method in class com.mulesoft.connectors.a2a.api.certificate.PublicKeyData
-
Returns the algorithm of the public key.
- getAuthentication() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig
- getAuthentication() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.push.model.AcceptedPushNotificationConfigParameterGroup
- getBasicConstraints() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the basic constraints.
- getBody() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext.Response
- getBufferedEvents() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.StreamingContext
- getBufferedEvents(TaskRepository, String) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.SseUtils
-
Gets buffered events for a task, returns empty list if none found
- getCard() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- getCard(boolean, boolean, RequestParameterGroup, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
- getCard(boolean, RequestParameterGroup, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
-
Fetches the agent card from the agent via "agent/card" operation.
- getCard(A2AClient, boolean, RequestParameterGroup, DistributedTraceContextManager, CompletionCallback<String, ResponseAttributes>) - Method in class com.mulesoft.connectors.a2a.internal.client.operation.ClientOperations
- getCategoryName() - Method in class com.mulesoft.connectors.a2a.internal.datasense.MessageSendParamsOutputResolver
- getCategoryName() - Method in class com.mulesoft.connectors.a2a.internal.datasense.PushNotificationConfigOutputResolver
- getCategoryName() - Method in class com.mulesoft.connectors.a2a.internal.datasense.TaskArtifactUpdateChainInputTypeResolver
- getCategoryName() - Method in class com.mulesoft.connectors.a2a.internal.datasense.TaskStatusUpdateChainInputTypeResolver
- getCategoryName() - Method in class com.mulesoft.connectors.a2a.internal.datasense.TaskTypeResolver
- getChainInputMetadataType(ChainInputMetadataContext) - Method in class com.mulesoft.connectors.a2a.internal.datasense.TaskArtifactUpdateChainInputTypeResolver
- getChainInputMetadataType(ChainInputMetadataContext) - Method in class com.mulesoft.connectors.a2a.internal.datasense.TaskStatusUpdateChainInputTypeResolver
- getClientCertificate() - Method in class com.mulesoft.connectors.a2a.api.certificate.ClientCertificateAware
- getClientCertificate() - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
- getClients(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseClientRegistry
- getCommonName() - Method in class com.mulesoft.connectors.a2a.api.certificate.PrincipalData
-
Extracts and returns the common name (CN) from the principal's name.
- getConfigName() - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- getContextId() - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
- getContextId() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.model.TaskIdentifiers
- getContextId() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.ContextRepositoryItem
- getContextId() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- getContextKey(String) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.ContextRepositoryItem
- getCriticalExtensionOIDs() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the critical extension OIDs.
- getCriticality() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateExtension
-
Returns the criticality of the extension.
- getCurrentWorkerId(MuleContext) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.SseUtils
-
Gets current worker instance ID from MuleContext.
- getDefaultMaxHistoryLength() - Method in class com.mulesoft.connectors.a2a.internal.server.TaskHistoryParameterGroup
- getDslTag() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener
- getEncoded() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the encoded form of the certificate.
- getEncoded() - Method in class com.mulesoft.connectors.a2a.api.certificate.PublicKeyData
-
Returns the encoded form of the public key.
- getError() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext.Response
- getErrorMessage() - Method in exception com.mulesoft.connectors.a2a.internal.error.exception.ClientException
-
Implementation of ErrorMessageAwareException - provides structured access to error response.
- getErrorTypes() - Method in class com.mulesoft.connectors.a2a.internal.error.provider.AgentCardErrorTypeProvider
- getErrorTypes() - Method in class com.mulesoft.connectors.a2a.internal.error.provider.BasicOperationErrorTypeProvider
- getErrorTypes() - Method in class com.mulesoft.connectors.a2a.internal.error.provider.JsonRpcErrorTypeProvider
- getErrorTypes() - Method in class com.mulesoft.connectors.a2a.internal.error.provider.PushNotificationErrorTypeProvider
- getErrorTypes() - Method in class com.mulesoft.connectors.a2a.internal.error.provider.StreamingErrorTypeProvider
- getEventData() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.sse.TaskEvent
- getEventId() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.sse.TaskEvent
- getEventType() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.sse.TaskEvent
- getExceptionalResponse(Object, Throwable, A2ASerializer) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.ServerAgentUtils
- getExtendedKeyUsage() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the extended key usage.
- getExtensions() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the certificate extensions.
- getExtensionValue(String) - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the value of the extension with the specified OID.
- getFile() - Method in class com.mulesoft.connectors.a2a.internal.server.AgentCardParameterGroup
- getFinalEventFound() - Method in class com.mulesoft.connectors.a2a.api.model.transport.StreamingResponseAttributes
-
Gets whether a final event was found during the SSE session.
- getFlavor() - Method in class com.mulesoft.connectors.a2a.internal.tracing.InboundSpanCustomizer
- getFlavor() - Method in class com.mulesoft.connectors.a2a.internal.tracing.OutboundSpanCustomizer
- getFlavor() - Method in class com.mulesoft.connectors.a2a.internal.tracing.SpanCustomizer
- getHeaders() - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
-
Gets the HTTP headers received in the request.
- getHeaders() - Method in class com.mulesoft.connectors.a2a.api.model.transport.ResponseAttributes
-
Gets the HTTP headers included in the response.
- getHeaders() - Method in exception com.mulesoft.connectors.a2a.internal.error.exception.AgentCardDiscoveryException.HttpErrorException
- getHeaders() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext.Response
- getHistory() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- getHistoryLength() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- getHttpRequestContext() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getHttpStatusCode() - Method in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
- getId() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig
- getIssuerAlternativeNames() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the issuer alternative names.
- getIssuerDN() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the issuer distinguished name.
- getIssuerUniqueID() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the issuer unique ID.
- getIssuerX500Principal() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the issuer X500 principal.
- getJson() - Method in class com.mulesoft.connectors.a2a.internal.server.AgentCardParameterGroup
- getJsonRpcCode() - Method in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
- getKeyUsage() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the key usage.
- getLocalAddress() - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
- getMessageHandler() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getMethod() - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
- getMethod() - Method in class com.mulesoft.connectors.a2a.internal.tracing.InboundSpanCustomizer
- getMethod() - Method in class com.mulesoft.connectors.a2a.internal.tracing.OutboundSpanCustomizer
- getMethod() - Method in class com.mulesoft.connectors.a2a.internal.tracing.SpanCustomizer
- getModulus() - Method in class com.mulesoft.connectors.a2a.api.certificate.PublicKeyData
-
Returns the modulus of the public key.
- getMuleContext() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getName() - Method in class com.mulesoft.connectors.a2a.api.certificate.AlternativeNameData
-
Returns the alternative name.
- getName() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the name of the subject distinguished name.
- getName() - Method in class com.mulesoft.connectors.a2a.api.certificate.PrincipalData
-
Returns the name of the principal.
- getName() - Method in class com.mulesoft.connectors.a2a.api.certificate.X500PrincipalData
-
Returns the name of the X.500 Principal.
- getNonCriticalExtensionOIDs() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the non-critical extension OIDs.
- getNotAfter() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the end date of the validity period.
- getNotBefore() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the start date of the validity period.
- getOid() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateExtension
-
Returns the OID of the extension.
- getParams() - Method in class com.mulesoft.connectors.a2a.api.certificate.PublicKeyData
-
Returns the parameters of the public key.
- getParent() - Method in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
- getPayloadAsInputStream(Object) - Method in class com.mulesoft.connectors.a2a.internal.protocol.A2ASerializer
- getPayloadAsString(Object) - Method in class com.mulesoft.connectors.a2a.internal.protocol.A2ASerializer
- getPollerScheduler() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getProtocol() - Method in class com.mulesoft.connectors.a2a.internal.tracing.InboundSpanCustomizer
- getProtocol() - Method in class com.mulesoft.connectors.a2a.internal.tracing.OutboundSpanCustomizer
- getProtocol() - Method in class com.mulesoft.connectors.a2a.internal.tracing.SpanCustomizer
- getProxy() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.push.model.AcceptedPushNotificationConfigParameterGroup
- getProxyConfig() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig
- getProxyConfig() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.push.model.AcceptedPushNotificationConfigParameterGroup
- getPublicKey() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the public key of the certificate.
- getPublicKey() - Method in class com.mulesoft.connectors.a2a.api.certificate.PublicKeyData
- getPushNotificationConfig(A2AClient, InputStream, RequestParameterGroup, DistributedTraceContextManager, CompletionCallback<String, ResponseAttributes>) - Method in class com.mulesoft.connectors.a2a.internal.client.operation.ClientOperations
- getPushNotificationConfig(InputStream, RequestParameterGroup, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
-
Fetches the specific push notification config from the agent via "tasks/pushNotificationConfig/get" operation.
- GetPushNotificationConfigHandler - Class in com.mulesoft.connectors.a2a.internal.server.agent.operations
- GetPushNotificationConfigHandler() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.operations.GetPushNotificationConfigHandler
- getPushNotificationConfigs() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- getPushNotificationConfigs(RequestHandlerContext, TaskRepositoryItem, String, String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.GetPushNotificationConfigHandler
- getQueryParams() - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
-
Gets the query parameters received in the HTTP request.
- getReasonPhrase() - Method in class com.mulesoft.connectors.a2a.api.model.transport.ResponseAttributes
-
Gets the reason phrase associated with the HTTP status code.
- getRegisteredMessageListenerLocation() - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- getRegisteredPushConfigListenerLocation() - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- getRegisteredStreamingListenerLocation() - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- getRemoteAddress() - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
- getRequest() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext
- getRequestAttributes() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext
- GetRequestHandler - Class in com.mulesoft.connectors.a2a.internal.server.agent.operations
-
Handles the retrieval of task information and history for the A2A protocol.
- GetRequestHandler() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.operations.GetRequestHandler
- getRequestId() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.StreamingContext
- getRequestId(String) - Static method in class com.mulesoft.connectors.a2a.internal.protocol.A2ASerializer
- getRequestMethod(String) - Static method in class com.mulesoft.connectors.a2a.internal.protocol.A2ASerializer
- getRequestTimeoutMillis() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.push.model.AcceptedPushNotificationConfigParameterGroup
- getRequestUri() - Method in exception com.mulesoft.connectors.a2a.internal.error.exception.AgentCardDiscoveryException
- getResolverName() - Method in class com.mulesoft.connectors.a2a.internal.datasense.MessageSendParamsOutputResolver
- getResolverName() - Method in class com.mulesoft.connectors.a2a.internal.datasense.PushNotificationConfigOutputResolver
- getResolverName() - Method in class com.mulesoft.connectors.a2a.internal.datasense.TaskArtifactUpdateChainInputTypeResolver
- getResolverName() - Method in class com.mulesoft.connectors.a2a.internal.datasense.TaskStatusUpdateChainInputTypeResolver
- getResolverName() - Method in class com.mulesoft.connectors.a2a.internal.datasense.TaskTypeResolver
- getResponse() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.model.TaskResponseParameterGroup
- getResponseAttributes() - Method in exception com.mulesoft.connectors.a2a.internal.error.exception.ClientException
-
Provides access to the response attributes (status code, headers, etc.)
- getResponseBody() - Method in exception com.mulesoft.connectors.a2a.internal.error.exception.ClientException
-
Provides access to the response body as a String.
- getResponseCallback() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getResponseFuture() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext
- getResponseHeaders() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.model.TaskErrorResponseParameterGroup
- getResponseHeaders() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.model.TaskResponseParameterGroup
- getResponseJson() - Method in exception com.mulesoft.connectors.a2a.internal.error.exception.AgentCardDiscoveryException.InvalidAgentCardException
- getRpcCode() - Method in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
- getRpcRequestContext() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getScheme() - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
- getSerialNumber() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the serial number of the certificate.
- getSerialNumber() - Method in class com.mulesoft.connectors.a2a.api.certificate.SerialNumberData
-
Returns the serial number.
- getSerialNumberObject() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the serial number as a SerialNumberData object.
- getServerAgent() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getServiceUrl() - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
- getSetPushNotificationConfigHandler() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getSigAlgName() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the signature algorithm name.
- getSigAlgOID() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the signature algorithm OID.
- getSigAlgParams() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the signature algorithm parameters.
- getSignature() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the signature.
- getSpanKind() - Method in class com.mulesoft.connectors.a2a.internal.tracing.InboundSpanCustomizer
- getSpanKind() - Method in class com.mulesoft.connectors.a2a.internal.tracing.OutboundSpanCustomizer
- getSpanKind() - Method in class com.mulesoft.connectors.a2a.internal.tracing.SpanCustomizer
- getSpecAgentCard() - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- getSseClientRegistry() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getSseClientRegistry() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- getStaticMetadata() - Method in class com.mulesoft.connectors.a2a.internal.datasense.MessageSendParamsOutputResolver
- getStaticMetadata() - Method in class com.mulesoft.connectors.a2a.internal.datasense.PushNotificationConfigOutputResolver
- getStaticMetadata() - Method in class com.mulesoft.connectors.a2a.internal.datasense.TaskTypeResolver
- getStatusCode() - Method in class com.mulesoft.connectors.a2a.api.model.transport.ResponseAttributes
-
Gets the HTTP status code of the response.
- getStatusCode() - Method in exception com.mulesoft.connectors.a2a.internal.error.exception.AgentCardDiscoveryException.HttpErrorException
- getStatusCode() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext.Response
- getStreamingContext() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
-
Gets the streaming context for this task.
- getSubjectAlternativeNames() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the subject alternative names.
- getSubjectDN() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the subject distinguished name.
- getSubjectX500Principal() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the subject X500 principal.
- getTask() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- getTask(A2AClient, InputStream, RequestParameterGroup, DistributedTraceContextManager, CompletionCallback<String, ResponseAttributes>) - Method in class com.mulesoft.connectors.a2a.internal.client.operation.ClientOperations
- getTask(InputStream, RequestParameterGroup, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
-
Fetches the task current state from the agent via "tasks/get" operation.
- getTask(String, int) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskStoreServiceImpl
-
Get task latest status with history.
- getTask(String, int) - Method in interface com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskStoreService
- getTaskHistory() - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- getTaskId() - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
- getTaskId() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.model.TaskIdentifiers
- getTaskIdentifiers(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.CancelTaskRequestHandler
- getTaskIdentifiers(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.DeletePushNotificationConfigHandler
- getTaskIdentifiers(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.GetPushNotificationConfigHandler
- getTaskIdentifiers(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.GetRequestHandler
- getTaskIdentifiers(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.ListPushNotificationConfigHandler
- getTaskIdentifiers(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.MessageStreamHandler
- getTaskIdentifiers(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.RequestHandler
- getTaskIdentifiers(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.SendMessageHandler
- getTaskIdentifiers(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.SetPushNotificationConfigHandler
- getTaskIdentifiers(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.TaskResubscribeHandler
- getTaskKey(String) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- getTaskPushNotificationConfig(String, EffectivePushNotificationConfig) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig
- getTaskPushNotificationConfigs(String, List<EffectivePushNotificationConfig>) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig
- getTaskRepository() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getTaskRepository() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- getTaskRepositoryObjectStore() - Method in class com.mulesoft.connectors.a2a.internal.server.TaskHistoryParameterGroup
- getTaskState() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- getTaskStoreService() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getTaskStoreService() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- getTaskStreamHandler() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext
- getTimeout() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig
- getTlsContextRef() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.push.model.ServerPushNotificationConfigParameterGroup
- getToken() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig
- getType() - Method in class com.mulesoft.connectors.a2a.api.certificate.AlternativeNameData
-
Returns the type of the alternative name.
- getType() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the type of the certificate.
- getURI() - Method in class com.mulesoft.connectors.a2a.internal.tracing.InboundSpanCustomizer
- getURI() - Method in class com.mulesoft.connectors.a2a.internal.tracing.OutboundSpanCustomizer
- getURI() - Method in class com.mulesoft.connectors.a2a.internal.tracing.SpanCustomizer
- getUrl() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig
- getValue() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateExtension
-
Returns the value of the extension.
- getVersion() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns the version of the certificate.
- getVersion() - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
- getWorkerInstanceId() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.StreamingContext
H
- handleAgentCardResponse(URI, Result<String, ResponseAttributes>, A2ASerializer) - Static method in class com.mulesoft.connectors.a2a.internal.client.helper.AgentCardHelper
-
Parses and validates the agent card from JSON.
- handleClientFailure(String, SseClient, TaskRepository, A2ASerializer, SseClientRegistry) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.SseUtils
-
Handles client failure - sends failure event to the specific client.
- handleInternalError(RpcRequestContext, Throwable) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.HandlerUtils
-
Handles internal error by completing the response future with an error response.
- HandlerUtils - Class in com.mulesoft.connectors.a2a.internal.server.agent.utils
- HandlerUtils() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.utils.HandlerUtils
- handleTaskNotCancelable(RpcRequestContext, Throwable) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.HandlerUtils
-
Handles internal error by completing the response future with an error response.
- handleTaskNotFound(RpcRequestContext) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.HandlerUtils
- hashCode() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
- hashCode() - Method in class com.mulesoft.connectors.a2a.api.certificate.PrincipalData
- hashCode() - Method in class com.mulesoft.connectors.a2a.api.certificate.X500PrincipalData
- hashCode() - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
- hashCode() - Method in class com.mulesoft.connectors.a2a.api.model.transport.ResponseAttributes
-
Returns a hash code value for the object.
- hashCode() - Method in class com.mulesoft.connectors.a2a.api.model.transport.StreamingResponseAttributes
-
Returns a hash code value for the object.
- hashCode() - Method in record class com.mulesoft.connectors.a2a.internal.client.model.SseConnectionResult
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.mulesoft.connectors.a2a.internal.client.model.SseSessionResult
-
Returns a hash code value for this object.
- hasUnsupportedCriticalExtension() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
-
Returns whether the certificate has unsupported critical extensions.
- headers(MultiMap<String, String>) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext.Response.Builder
- HTTP_FLAVOR - Static variable in class com.mulesoft.connectors.a2a.internal.tracing.SpanCustomizer
- HTTP_METHOD - Static variable in class com.mulesoft.connectors.a2a.internal.tracing.SpanCustomizer
- HTTP_STATUS_CODE - Static variable in class com.mulesoft.connectors.a2a.internal.tracing.TracingUtils
- HttpErrorException(int, String, URI, Map<String, String>) - Constructor for exception com.mulesoft.connectors.a2a.internal.error.exception.AgentCardDiscoveryException.HttpErrorException
- HttpServerConnectionProvider - Class in com.mulesoft.connectors.a2a.internal.server.connection.http
- HttpServerConnectionProvider() - Constructor for class com.mulesoft.connectors.a2a.internal.server.connection.http.HttpServerConnectionProvider
- HttpUtils - Class in com.mulesoft.connectors.a2a.internal.util.certificate
- HttpUtils() - Constructor for class com.mulesoft.connectors.a2a.internal.util.certificate.HttpUtils
I
- id(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig.Builder
- InboundSpanCustomizer - Class in com.mulesoft.connectors.a2a.internal.tracing
-
A customizer for the current span for HTTP Requests
- InboundSpanCustomizer(DistributedTraceContextManager, String, String, Integer, String, String, MultiMap<String, String>, String) - Constructor for class com.mulesoft.connectors.a2a.internal.tracing.InboundSpanCustomizer
- initialise() - Method in class com.mulesoft.connectors.a2a.internal.client.connection.provider.ClientConnectionProvider
- initialise() - Method in class com.mulesoft.connectors.a2a.internal.server.connection.http.HttpServerConnectionProvider
- initialise() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener
- initialise() - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- initServer(ServerConfig, ComponentLocation, Consumer<RpcRequestContext>) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- INSTANCE - Static variable in class com.mulesoft.connectors.a2a.internal.server.agent.repository.NullTaskRepository
- INTERNAL_ERROR - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
Internal error either on the remove server or this connector
- INVALID_AGENT_CARD - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
Invalid agent card
- INVALID_PARAMS - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
Supplied parameters were invalid
- INVALID_REQUEST - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
The request was invalid or malformed
- InvalidAgentCardException(String, URI, String, Throwable) - Constructor for exception com.mulesoft.connectors.a2a.internal.error.exception.AgentCardDiscoveryException.InvalidAgentCardException
- isClientRegistered(String, SseClient) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseClientRegistry
-
Checks if a specific client is still registered for a taskId
- isCrossWorkerScenario(TaskRepositoryItem, String) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.SseUtils
-
Determines if the current event represents a cross-worker scenario.
- isFinalEvent(StreamingEventKind) - Static method in class com.mulesoft.connectors.a2a.internal.util.A2AUtils
-
Checks if sse event data represents a final TaskStatusUpdateEvent using A2A SDK.
- isJsonRpcError() - Method in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
- isMessageListenerRegistered() - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- isPushConfigListenerRegistered() - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- isStreamingListenerRegistered() - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- isTaskHistoryEnabled() - Method in class com.mulesoft.connectors.a2a.internal.server.TaskHistoryParameterGroup
- isValidUrl(String) - Static method in class com.mulesoft.connectors.a2a.internal.util.certificate.HttpUtils
-
Validates if the given URL is a valid HTTP/HTTPS URL.
J
- JSON_RPC_ERROR - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
Parent type for errors that match those defined in the Json RPC standard
- JsonRpcErrorTypeProvider - Class in com.mulesoft.connectors.a2a.internal.error.provider
-
Returns the error types that match the Json RPC error defined in that standard
- JsonRpcErrorTypeProvider() - Constructor for class com.mulesoft.connectors.a2a.internal.error.provider.JsonRpcErrorTypeProvider
L
- ListPushNotificationConfigHandler - Class in com.mulesoft.connectors.a2a.internal.server.agent.operations
- ListPushNotificationConfigHandler() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.operations.ListPushNotificationConfigHandler
- listPushNotificationConfigs(A2AClient, InputStream, RequestParameterGroup, DistributedTraceContextManager, CompletionCallback<String, ResponseAttributes>) - Method in class com.mulesoft.connectors.a2a.internal.client.operation.ClientOperations
- listPushNotificationConfigs(InputStream, RequestParameterGroup, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
-
Fetches all push notification config from the agent via "tasks/pushNotificationConfig/list" operation.
M
- messageHandler(Consumer<RpcRequestContext>) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- MessageSendParamsOutputResolver - Class in com.mulesoft.connectors.a2a.internal.datasense
- MessageSendParamsOutputResolver() - Constructor for class com.mulesoft.connectors.a2a.internal.datasense.MessageSendParamsOutputResolver
- MessageStreamHandler - Class in com.mulesoft.connectors.a2a.internal.server.agent.operations
- MessageStreamHandler() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.operations.MessageStreamHandler
- METHOD_NOT_FOUND - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
The remote MCP server does not support the given method, most likely due to a version incompatibility or a bug
- muleContext(MuleContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
N
- newRequestBuilder(HttpRequestAuthentication) - Static method in class com.mulesoft.connectors.a2a.internal.util.A2AUtils
- NotFoundException(URI) - Constructor for exception com.mulesoft.connectors.a2a.internal.error.exception.AgentCardDiscoveryException.NotFoundException
- NullTaskRepository - Class in com.mulesoft.connectors.a2a.internal.server.agent.repository
- NullTaskRepository() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.repository.NullTaskRepository
O
- ObjectStoreAccessor<T extends Serializable> - Class in com.mulesoft.connectors.a2a.internal.util
- ObjectStoreAccessor(ObjectStore<T>, LockFactory, Function<String, String>) - Constructor for class com.mulesoft.connectors.a2a.internal.util.ObjectStoreAccessor
- ofJsonSchema(String, String) - Static method in class com.mulesoft.connectors.a2a.internal.datasense.DataSenseUtils
-
Loads a metadata type from a JSON schema resource file.
- onError(TaskErrorResponseParameterGroup, Error, SourceCallbackContext, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.TaskListener
- onError(Error, SourceCallbackContext) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.push.PushNotificationConfigListener
- onError(Error, SourceCallbackContext) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.TaskStreamListener
- onSetPushNotificationConfigHandler(Function<RpcRequestContext, CompletableFuture<EffectivePushNotificationConfig>>) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- onStart(SourceCallback<String, RequestAttributes>) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.push.PushNotificationConfigListener
- onStart(SourceCallback<String, RequestAttributes>) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.TaskListener
- onStart(SourceCallback<String, RequestAttributes>) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.TaskStreamListener
- onStop() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.push.PushNotificationConfigListener
- onStop() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.TaskListener
- onStop() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.TaskStreamListener
- onSuccess(AcceptedPushNotificationConfigParameterGroup, SourceCallbackContext) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.push.PushNotificationConfigListener
- onSuccess(TaskResponseParameterGroup, SourceCallbackContext, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.TaskListener
- onTerminate() - Method in class com.mulesoft.connectors.a2a.internal.server.listener.push.PushNotificationConfigListener
- onTerminate(SourceResult) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.TaskListener
- originalAttributes() - Method in record class com.mulesoft.connectors.a2a.internal.client.model.SseSessionResult
-
Returns the value of the
originalAttributesrecord component. - OutboundSpanCustomizer - Class in com.mulesoft.connectors.a2a.internal.tracing
-
A customizer for the current span for HTTP Requests
- OutboundSpanCustomizer(DistributedTraceContextManager, HttpRequest) - Constructor for class com.mulesoft.connectors.a2a.internal.tracing.OutboundSpanCustomizer
P
- PARSE_ERROR - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
Occurs when a JSON object could not be parsed and/or is malformed
- parseAgentCard(URI, String, A2ASerializer) - Static method in class com.mulesoft.connectors.a2a.internal.client.helper.AgentCardHelper
-
Converts a JSON string to an AgentCard using the provided serializer.
- POLLER_INTERVAL_SECONDS - Static variable in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseConstants
-
Polling interval in seconds for cross-worker SSE event delivery.
- pollerScheduler(Scheduler) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- PrincipalData - Class in com.mulesoft.connectors.a2a.api.certificate
-
A custom Data Transfer Object (DTO) to replace the
Principalclass. - PrincipalData(String) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.PrincipalData
-
Constructs a new
PrincipalDatainstance with the specified name. - propagateTraceContext(HttpRequestBuilder, DistributedTraceContextManager) - Static method in class com.mulesoft.connectors.a2a.internal.tracing.TracingUtils
- proxyConfig(HttpProxyConfig) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig.Builder
- PublicKeyData - Class in com.mulesoft.connectors.a2a.api.certificate
-
A custom Data Transfer Object (DTO) to replace the
PublicKeyclass. - PublicKeyData(String, byte[]) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.PublicKeyData
-
Constructs a new
PublicKeyDatainstance with the specified algorithm and encoded form. - PublicKeyData(String, BigInteger, BigInteger, String, byte[]) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.PublicKeyData
-
Constructs a new
PublicKeyDatainstance with detailed attributes. - PUSH_NOTIFICATION_UNSUPPORTED - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
Push notifications not supported by the agent
- PushNotificationConfigListener - Class in com.mulesoft.connectors.a2a.internal.server.listener.push
- PushNotificationConfigListener() - Constructor for class com.mulesoft.connectors.a2a.internal.server.listener.push.PushNotificationConfigListener
- PushNotificationConfigOutputResolver - Class in com.mulesoft.connectors.a2a.internal.datasense
- PushNotificationConfigOutputResolver() - Constructor for class com.mulesoft.connectors.a2a.internal.datasense.PushNotificationConfigOutputResolver
- PushNotificationErrorTypeProvider - Class in com.mulesoft.connectors.a2a.internal.error.provider
- PushNotificationErrorTypeProvider() - Constructor for class com.mulesoft.connectors.a2a.internal.error.provider.PushNotificationErrorTypeProvider
R
- recoverRequestContext(SourceCallbackContext) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener
- register(String, SseClient) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseClientRegistry
- remove(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskRepository
- remove(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.NullTaskRepository
- remove(String) - Method in interface com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepository
- remove(String) - Method in class com.mulesoft.connectors.a2a.internal.util.ObjectStoreAccessor
- removeClient(String, SseClient) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseClientRegistry
- removePushNotificationHandler() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- removeTask(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseClientRegistry
- removeTaskStreamHandler() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- replayBufferedEventsToClient(List<TaskEvent>, String, SseClient, TaskRepository, A2ASerializer, SseClientRegistry) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.SseUtils
-
Sends buffered events to a specific SSE client (for resubscribe scenarios)
- RepositoryItem - Class in com.mulesoft.connectors.a2a.internal.server.agent.repository
- RepositoryItem() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.repository.RepositoryItem
- REQUEST_CONTEXT_VAR - Static variable in class com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener
- REQUEST_TIMEOUT - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
The request timed out.
- RequestAttributes - Class in com.mulesoft.connectors.a2a.api.listener
-
Represents the HTTP request attributes for an A2A incoming request.
- RequestAttributes(String, String, MultiMap<String, String>, MultiMap<String, String>, String, String, String, String, String, Supplier<CertificateData>) - Constructor for class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
-
Creates a new RequestAttributes instance with the specified query parameters and headers.
- requestContext(HttpRequestContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- RequestHandler - Class in com.mulesoft.connectors.a2a.internal.server.agent.operations
-
Super class encapsulating all tasks Server can handle.
- RequestHandler() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.operations.RequestHandler
- RequestHandlerContext - Class in com.mulesoft.connectors.a2a.internal.server.agent
- RequestHandlerContext.Builder - Class in com.mulesoft.connectors.a2a.internal.server.agent
- RequestParameterGroup - Class in com.mulesoft.connectors.a2a.api.model.transport
-
Parameter group for handling additional request properties in A2A connector operations.
- RequestParameterGroup() - Constructor for class com.mulesoft.connectors.a2a.api.model.transport.RequestParameterGroup
- responseAttributes() - Method in record class com.mulesoft.connectors.a2a.internal.client.model.SseConnectionResult
-
Returns the value of the
responseAttributesrecord component. - ResponseAttributes - Class in com.mulesoft.connectors.a2a.api.model.transport
-
Represents the HTTP response attributes for an A2A request.
- ResponseAttributes(int, MultiMap<String, String>, String) - Constructor for class com.mulesoft.connectors.a2a.api.model.transport.ResponseAttributes
-
Creates a new ResponseAttributes instance with the specified status code, headers, and reason phrase.
- ResponseAttributesHelper - Class in com.mulesoft.connectors.a2a.internal.client.helper
-
Utility class for creating ResponseAttributes objects from HTTP responses.
- responseCallback(HttpResponseReadyCallback) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- rpcRequestContext(RpcRequestContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- RpcRequestContext - Class in com.mulesoft.connectors.a2a.internal.server.agent
- RpcRequestContext(JSONRPCRequest, RequestAttributes) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext
- RpcRequestContext.Response - Class in com.mulesoft.connectors.a2a.internal.server.agent
- RpcRequestContext.Response.Builder - Class in com.mulesoft.connectors.a2a.internal.server.agent
S
- SCHEDULER_MAX_CONCURRENT_TASKS - Static variable in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseConstants
-
Maximum concurrent tasks for the A2A scheduler used for SSE polling.
- SCHEDULER_WAIT_ALLOWED - Static variable in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseConstants
-
Whether the A2A scheduler allows waiting (blocking) operations.
- sendExceptionalHttpResponse(Object, Throwable, HttpResponseReadyCallback, A2ASerializer) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.ServerAgentUtils
- sendFailureHttpResponse(Integer, A2AErrorTypes, String, Object, HttpResponseReadyCallback, A2ASerializer) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.ServerAgentUtils
- sendHttpResponse(int, String, MultiMap<String, String>, HttpResponseReadyCallback) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.ServerAgentUtils
- sendHttpResponse(int, String, HttpResponseReadyCallback) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.ServerAgentUtils
- sendHttpResponse(HttpResponse, HttpResponseReadyCallback) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.ServerAgentUtils
- sendMessage(A2AClient, InputStream, RequestParameterGroup, DistributedTraceContextManager, CompletionCallback<String, ResponseAttributes>) - Method in class com.mulesoft.connectors.a2a.internal.client.operation.ClientOperations
- sendMessage(InputStream, RequestParameterGroup, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
-
Redirects the request to the agent from the client for "message/send" operation.
- SendMessageHandler - Class in com.mulesoft.connectors.a2a.internal.server.agent.operations
- SendMessageHandler(boolean) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.operations.SendMessageHandler
- sendPushNotification(ServerAgent, InputStream, CompletionCallback<Void, Void>) - Method in class com.mulesoft.connectors.a2a.internal.server.operation.ServerOperations
-
Sends a push notification with the provided task or message payload.
- sendPushNotificationCallback(String, EffectivePushNotificationConfig, String, boolean) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
-
Sends a push notification callback to the configured URL with the provided JSON-RPC formatted body.
- sendPushNotificationNotSupportedResponse(RequestHandlerContext) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.ServerAgentUtils
- sendPushNotificationUpdate(String, String, boolean) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
-
Sends a push notification update for a specific task.
- sendStreamingNotSupportedResponse(RequestHandlerContext) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.ServerAgentUtils
- sendStreamMessage(A2AClient, InputStream, RequestParameterGroup, DistributedTraceContextManager, TaskStatusUpdateRoute, TaskArtifactUpdateRoute, CompletionCallback<String, StreamingResponseAttributes>) - Method in class com.mulesoft.connectors.a2a.internal.client.operation.ClientOperations
-
Sends a message to the A2A agent and establishes an SSE streaming connection to receive real-time status updates, artifacts, and error notifications as the agent processes the request.
- sendStreamMessage(InputStream, RequestParameterGroup, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
- sendSubmittedAcceptedResponse(Object, HttpResponseReadyCallback, String, String, A2ASerializer) - Static method in class com.mulesoft.connectors.a2a.internal.server.agent.utils.ServerAgentUtils
- SerialNumberData - Class in com.mulesoft.connectors.a2a.api.certificate
-
A custom Data Transfer Object (DTO) to replace the
CertificateSerialNumber class. - SerialNumberData(BigInteger) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.SerialNumberData
-
Constructs a new
SerialNumberDatainstance with the specified serial number. - SERVER_ERROR - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
- serverAgent - Variable in class com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener
- serverAgent(ServerAgent) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- ServerAgent - Class in com.mulesoft.connectors.a2a.internal.server.agent
- ServerAgent(HttpServer, String, LockFactory, ObjectStoreManager, HttpClient, A2ASerializer, MuleContext, Scheduler) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- ServerAgentUtils - Class in com.mulesoft.connectors.a2a.internal.server.agent.utils
- ServerConfig - Class in com.mulesoft.connectors.a2a.internal.server
- ServerConfig() - Constructor for class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- ServerOperations - Class in com.mulesoft.connectors.a2a.internal.server.operation
-
Operations available for the server configuration that can be used within flows.
- ServerOperations() - Constructor for class com.mulesoft.connectors.a2a.internal.server.operation.ServerOperations
- ServerPushNotificationConfigParameterGroup - Class in com.mulesoft.connectors.a2a.internal.server.listener.push.model
- ServerPushNotificationConfigParameterGroup() - Constructor for class com.mulesoft.connectors.a2a.internal.server.listener.push.model.ServerPushNotificationConfigParameterGroup
- setBaseUrl(String) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
- setContextId(String) - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
- setContextId(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.ContextRepositoryItem
- setContextId(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- setHistory(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- setHistoryLength(int) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- setMessageListenerRegistered(boolean) - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- setMessageListenerRegistered(boolean, String) - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- setPushConfigListenerRegistered(boolean) - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- setPushConfigListenerRegistered(boolean, String) - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- setPushNotificationConfig(A2AClient, InputStream, RequestParameterGroup, DistributedTraceContextManager, CompletionCallback<String, ResponseAttributes>) - Method in class com.mulesoft.connectors.a2a.internal.client.operation.ClientOperations
- setPushNotificationConfig(InputStream, RequestParameterGroup, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
-
Update push notification config for task via "tasks/pushNotificationConfig/set" operation.
- SetPushNotificationConfigHandler - Class in com.mulesoft.connectors.a2a.internal.server.agent.operations
-
Handles setting push notification configurations for tasks.
- SetPushNotificationConfigHandler() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.operations.SetPushNotificationConfigHandler
- setPushNotificationConfigs(List<EffectivePushNotificationConfig>) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- setPushNotificationHandler(Function<RpcRequestContext, CompletableFuture<EffectivePushNotificationConfig>>) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- setRequestId(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.StreamingContext
- setResponse(InputStream) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.model.TaskResponseParameterGroup
- setResponseHeaders(MultiMap<String, String>) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.model.TaskErrorResponseParameterGroup
- setResponseHeaders(MultiMap<String, String>) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.task.model.TaskResponseParameterGroup
- setStreamingContext(StreamingContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
-
Sets the streaming context for this task.
- setStreamingListenerRegistered(boolean) - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- setStreamingListenerRegistered(boolean, String) - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- setTask(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- setTaskId(String) - Method in class com.mulesoft.connectors.a2a.api.listener.RequestAttributes
- setTaskRepository(TaskRepository) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
-
Sets the task repository.
- setTaskState(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- setTaskStoreService(TaskStoreService) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
-
Sets the task store service.
- setTaskStreamHandler(Function<RpcRequestContext, CompletableFuture<Void>>) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- setupResponseHandler(RequestHandlerContext) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.RequestHandler
- setWorkerInstanceId(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.StreamingContext
- shutdown() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseClientRegistry
-
Shuts down the SSE client registry by closing all connections and clearing the registry.
- SPAN_KIND - Static variable in class com.mulesoft.connectors.a2a.internal.tracing.SpanCustomizer
- SPAN_STATUS - Static variable in class com.mulesoft.connectors.a2a.internal.tracing.TracingUtils
- SpanCustomizer - Class in com.mulesoft.connectors.a2a.internal.tracing
-
A customizer for the current span for HTTP
- SpanCustomizer(DistributedTraceContextManager) - Constructor for class com.mulesoft.connectors.a2a.internal.tracing.SpanCustomizer
- sseClientRegistry(SseClientRegistry) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- SseClientRegistry - Class in com.mulesoft.connectors.a2a.internal.server.agent.sse
-
Registry for managing SSE client connections and event routing.
- SseClientRegistry() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseClientRegistry
- SseConnectionResult - Record Class in com.mulesoft.connectors.a2a.internal.client.model
-
Encapsulates the result of establishing an SSE connection, containing both the SSE source and the HTTP response attributes from the initial connection.
- SseConnectionResult(SseSource, ResponseAttributes) - Constructor for record class com.mulesoft.connectors.a2a.internal.client.model.SseConnectionResult
-
Creates an instance of a
SseConnectionResultrecord class. - SseConstants - Class in com.mulesoft.connectors.a2a.internal.server.agent.sse
-
Constants for SSE event types and configuration values.
- SseManager - Class in com.mulesoft.connectors.a2a.internal.client.operation
- SseManager(A2ASerializer) - Constructor for class com.mulesoft.connectors.a2a.internal.client.operation.SseManager
- SseSessionResult - Record Class in com.mulesoft.connectors.a2a.internal.client.model
-
Encapsulates the result of an SSE session, containing all collected events and metadata about the session completion.
- SseSessionResult(List<StreamingEventKind>, ResponseAttributes, boolean) - Constructor for record class com.mulesoft.connectors.a2a.internal.client.model.SseSessionResult
-
Creates an instance of a
SseSessionResultrecord class. - sseSource() - Method in record class com.mulesoft.connectors.a2a.internal.client.model.SseConnectionResult
-
Returns the value of the
sseSourcerecord component. - SseUtils - Class in com.mulesoft.connectors.a2a.internal.server.agent.utils
-
SSE-specific utility methods for handlers
- SseUtils() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.utils.SseUtils
- start() - Method in class com.mulesoft.connectors.a2a.internal.client.connection.provider.ClientConnectionProvider
- start() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.sse.CrossWorkerPoller
-
Starts the poller.
- start() - Method in class com.mulesoft.connectors.a2a.internal.server.connection.http.HttpServerConnectionProvider
- start() - Method in class com.mulesoft.connectors.a2a.internal.server.ServerConfig
- startSseSession(SseConnectionResult, TaskStatusUpdateRoute, TaskArtifactUpdateRoute) - Method in class com.mulesoft.connectors.a2a.internal.client.operation.SseManager
-
Starts an SSE session, handling events and executing routes until the session completes.
- STATUS_UPDATE_EVENT - Static variable in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseConstants
-
SSE event type for task status updates.
- statusCode(int) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RpcRequestContext.Response.Builder
- stop() - Method in class com.mulesoft.connectors.a2a.internal.client.connection.provider.ClientConnectionProvider
- stop() - Method in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- stop() - Method in class com.mulesoft.connectors.a2a.internal.server.connection.http.HttpServerConnectionProvider
- storeInContext(RpcRequestContext, SourceCallbackContext) - Method in class com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener
- StreamingContext - Class in com.mulesoft.connectors.a2a.internal.server.agent.repository
-
Groups all SSE/streaming-related context data for a task.
- StreamingContext() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.repository.StreamingContext
-
Default constructor for serialization and cases where context is built incrementally.
- StreamingContext(String, String) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.repository.StreamingContext
-
Constructor for creating a complete streaming context.
- StreamingErrorTypeProvider - Class in com.mulesoft.connectors.a2a.internal.error.provider
- StreamingErrorTypeProvider() - Constructor for class com.mulesoft.connectors.a2a.internal.error.provider.StreamingErrorTypeProvider
- StreamingResponseAttributes - Class in com.mulesoft.connectors.a2a.api.model.transport
-
Represents the HTTP response attributes for A2A streaming operations (SSE).
- StreamingResponseAttributes(int, MultiMap<String, String>, String, Boolean) - Constructor for class com.mulesoft.connectors.a2a.api.model.transport.StreamingResponseAttributes
-
Creates a new StreamingResponseAttributes instance with the specified status code, headers, reason phrase, and SSE info.
T
- TASK_EVENT - Static variable in class com.mulesoft.connectors.a2a.internal.server.agent.sse.SseConstants
-
SSE event type for initial task events.
- TASK_NOT_CANCELABLE - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
Requested task already completed cannot be cancelled
- TASK_NOT_FOUND - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
Requested task is not found or doesn't exist
- TASK_OS_TTL - Static variable in class com.mulesoft.connectors.a2a.internal.server.agent.ServerAgent
- TaskArtifactUpdateChainInputTypeResolver - Class in com.mulesoft.connectors.a2a.internal.datasense
-
Resolves the input metadata type for Task Artifact Update SSE event routes.
- TaskArtifactUpdateChainInputTypeResolver() - Constructor for class com.mulesoft.connectors.a2a.internal.datasense.TaskArtifactUpdateChainInputTypeResolver
- TaskArtifactUpdateRoute - Class in com.mulesoft.connectors.a2a.internal.client.route
-
Route for handling task artifact update events from SSE stream.
- TaskArtifactUpdateRoute() - Constructor for class com.mulesoft.connectors.a2a.internal.client.route.TaskArtifactUpdateRoute
- TaskErrorResponseParameterGroup - Class in com.mulesoft.connectors.a2a.internal.server.listener.task.model
- TaskErrorResponseParameterGroup() - Constructor for class com.mulesoft.connectors.a2a.internal.server.listener.task.model.TaskErrorResponseParameterGroup
- TaskEvent - Class in com.mulesoft.connectors.a2a.internal.server.agent.sse
-
Immutable representation of a single SSE event that can be stored in Object Store for cross-worker delivery and client reconnection scenarios.
- TaskEvent() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.sse.TaskEvent
-
Default constructor to create an event with generated ID
- TaskEvent(String, String) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.sse.TaskEvent
-
Creates a TaskEvent with the specified type and data.
- TaskHistoryParameterGroup - Class in com.mulesoft.connectors.a2a.internal.server
- TaskHistoryParameterGroup() - Constructor for class com.mulesoft.connectors.a2a.internal.server.TaskHistoryParameterGroup
- TaskIdentifiers - Class in com.mulesoft.connectors.a2a.internal.server.agent.model
- TaskIdentifiers(String) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.model.TaskIdentifiers
- TaskIdentifiers(String, String) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.model.TaskIdentifiers
- TaskListener - Class in com.mulesoft.connectors.a2a.internal.server.listener.task
- TaskListener() - Constructor for class com.mulesoft.connectors.a2a.internal.server.listener.task.TaskListener
- taskRepository(TaskRepository) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- TaskRepository - Interface in com.mulesoft.connectors.a2a.internal.server.agent.repository
- TaskRepositoryItem - Class in com.mulesoft.connectors.a2a.internal.server.agent.repository
-
Repository item that stores task JSON and push notification configs.
- TaskRepositoryItem() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- TaskRepositoryItem(String) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- TaskRepositoryItem(String, List<EffectivePushNotificationConfig>) - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepositoryItem
- TaskResponseParameterGroup - Class in com.mulesoft.connectors.a2a.internal.server.listener.task.model
- TaskResponseParameterGroup() - Constructor for class com.mulesoft.connectors.a2a.internal.server.listener.task.model.TaskResponseParameterGroup
- taskResubscribe(A2AClient, InputStream, RequestParameterGroup, DistributedTraceContextManager, TaskStatusUpdateRoute, TaskArtifactUpdateRoute, CompletionCallback<String, StreamingResponseAttributes>) - Method in class com.mulesoft.connectors.a2a.internal.client.operation.ClientOperations
-
Reconnects to an existing SSE streaming session for an ongoing task to receive buffered events and continue receiving real-time updates from where the connection was lost.
- taskResubscribe(InputStream, RequestParameterGroup, DistributedTraceContextManager) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.A2AClient
- TaskResubscribeHandler - Class in com.mulesoft.connectors.a2a.internal.server.agent.operations
-
Handler for tasks/resubscribe JSON-RPC method.
- TaskResubscribeHandler() - Constructor for class com.mulesoft.connectors.a2a.internal.server.agent.operations.TaskResubscribeHandler
- TaskStatusUpdateChainInputTypeResolver - Class in com.mulesoft.connectors.a2a.internal.datasense
-
Resolves the input metadata type for Task Status Update SSE event routes.
- TaskStatusUpdateChainInputTypeResolver() - Constructor for class com.mulesoft.connectors.a2a.internal.datasense.TaskStatusUpdateChainInputTypeResolver
- TaskStatusUpdateRoute - Class in com.mulesoft.connectors.a2a.internal.client.route
-
Route for handling task status update events from SSE stream.
- TaskStatusUpdateRoute() - Constructor for class com.mulesoft.connectors.a2a.internal.client.route.TaskStatusUpdateRoute
- taskStoreService(TaskStoreService) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- TaskStoreService - Interface in com.mulesoft.connectors.a2a.internal.server.agent.repository
- taskStreamHandler(Function<RpcRequestContext, CompletableFuture<Void>>) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.RequestHandlerContext.Builder
- TaskStreamListener - Class in com.mulesoft.connectors.a2a.internal.server.listener.task
-
Server-side listener for streaming task requests.
- TaskStreamListener() - Constructor for class com.mulesoft.connectors.a2a.internal.server.listener.task.TaskStreamListener
- TaskTypeResolver - Class in com.mulesoft.connectors.a2a.internal.datasense
- TaskTypeResolver() - Constructor for class com.mulesoft.connectors.a2a.internal.datasense.TaskTypeResolver
- timeout(int) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig.Builder
- token(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig.Builder
- toString() - Method in class com.mulesoft.connectors.a2a.api.certificate.AlternativeNameData
- toString() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateData
- toString() - Method in class com.mulesoft.connectors.a2a.api.certificate.CertificateExtension
- toString() - Method in class com.mulesoft.connectors.a2a.api.certificate.PrincipalData
- toString() - Method in class com.mulesoft.connectors.a2a.api.certificate.PublicKeyData
- toString() - Method in class com.mulesoft.connectors.a2a.api.certificate.X500PrincipalData
- toString() - Method in record class com.mulesoft.connectors.a2a.internal.client.model.SseConnectionResult
-
Returns a string representation of this record class.
- toString() - Method in record class com.mulesoft.connectors.a2a.internal.client.model.SseSessionResult
-
Returns a string representation of this record class.
- traceContextManager - Variable in class com.mulesoft.connectors.a2a.internal.tracing.SpanCustomizer
- traceOutboundRequest(DistributedTraceContextManager, HttpRequest) - Static method in class com.mulesoft.connectors.a2a.internal.tracing.TracingUtils
- traceResponseStatusCode(DistributedTraceContextManager, int, Logger) - Static method in class com.mulesoft.connectors.a2a.internal.tracing.TracingUtils
-
Adds the status code attribute.
- TracingUtils - Class in com.mulesoft.connectors.a2a.internal.tracing
-
Utils for Otel tracing
U
- UNAUTHORIZED - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
Client not Authorized
- unmarshall(InputStream, TypeReference<T>) - Method in class com.mulesoft.connectors.a2a.internal.protocol.A2ASerializer
- unmarshall(String, TypeReference<T>) - Method in class com.mulesoft.connectors.a2a.internal.protocol.A2ASerializer
- UNSET_STATUS - Static variable in class com.mulesoft.connectors.a2a.internal.tracing.TracingUtils
- UNSUPPORTED_OPERATION - Enum constant in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
Operation not supported by the agent
- updateHistory(String, String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskStoreServiceImpl
-
Update the taskRepository item history list with the new history message.
- updateHistory(String, String) - Method in interface com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskStoreService
- updatePushNotificationConfig(String, EffectivePushNotificationConfig) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskStoreServiceImpl
- updatePushNotificationConfig(String, EffectivePushNotificationConfig) - Method in interface com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskStoreService
- updateTask(String, String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskStoreServiceImpl
-
Update the taskRepository item task string with the updated task.
- updateTask(String, String) - Method in interface com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskStoreService
- updateTaskArtifact(ServerAgent, InputStream) - Method in class com.mulesoft.connectors.a2a.internal.server.operations.UpdateTaskArtifactOperation
-
Updates a task artifact and broadcasts the update to all connected SSE clients.
- UpdateTaskArtifactOperation - Class in com.mulesoft.connectors.a2a.internal.server.operations
-
Server operation to update task artifacts and broadcast the update to connected SSE clients.
- UpdateTaskArtifactOperation() - Constructor for class com.mulesoft.connectors.a2a.internal.server.operations.UpdateTaskArtifactOperation
- updateTaskStatus(ServerAgent, InputStream) - Method in class com.mulesoft.connectors.a2a.internal.server.operations.UpdateTaskStatusOperation
-
Updates a task status and broadcasts the update to all connected SSE clients.
- UpdateTaskStatusOperation - Class in com.mulesoft.connectors.a2a.internal.server.operations
-
Server operation to update task status and broadcast the update to connected SSE clients.
- UpdateTaskStatusOperation() - Constructor for class com.mulesoft.connectors.a2a.internal.server.operations.UpdateTaskStatusOperation
- upsert(String, RepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskRepository
- upsert(String, RepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.NullTaskRepository
- upsert(String, RepositoryItem) - Method in interface com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepository
- upsert(String, String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.repository.DefaultTaskStoreServiceImpl
-
Create new entry for provided taskId and contextId in object store
- upsert(String, String) - Method in interface com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskStoreService
- upsert(String, T) - Method in class com.mulesoft.connectors.a2a.internal.util.ObjectStoreAccessor
- url(String) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.push.EffectivePushNotificationConfig.Builder
V
- validate(A2AClient) - Method in class com.mulesoft.connectors.a2a.internal.client.connection.provider.ClientConnectionProvider
- validate(RequestHandlerContext, TaskRepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.CancelTaskRequestHandler
- validate(RequestHandlerContext, TaskRepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.DeletePushNotificationConfigHandler
- validate(RequestHandlerContext, TaskRepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.GetPushNotificationConfigHandler
- validate(RequestHandlerContext, TaskRepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.GetRequestHandler
- validate(RequestHandlerContext, TaskRepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.ListPushNotificationConfigHandler
- validate(RequestHandlerContext, TaskRepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.MessageStreamHandler
- validate(RequestHandlerContext, TaskRepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.RequestHandler
- validate(RequestHandlerContext, TaskRepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.SendMessageHandler
- validate(RequestHandlerContext, TaskRepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.SetPushNotificationConfigHandler
- validate(RequestHandlerContext, TaskRepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.TaskResubscribeHandler
- validate(ServerAgent) - Method in class com.mulesoft.connectors.a2a.internal.server.connection.http.HttpServerConnectionProvider
- validateContext(RequestHandlerContext, ContextRepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.RequestHandler
- validateServerUrl(String) - Static method in class com.mulesoft.connectors.a2a.internal.client.helper.AgentCardHelper
-
Validates the server URL and returns a URI object.
- validateTask(RequestHandlerContext, TaskRepositoryItem) - Method in class com.mulesoft.connectors.a2a.internal.server.agent.operations.RequestHandler
- valueOf(String) - Static method in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class com.mulesoft.connectors.a2a.internal.error.A2AErrorTypes
-
Returns an array containing the constants of this enum class, in the order they are declared.
X
- X500PrincipalData - Class in com.mulesoft.connectors.a2a.api.certificate
-
A custom Data Transfer Object (DTO) to replace the
PrincipalX509Principal class. - X500PrincipalData(PrincipalData) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.X500PrincipalData
-
Constructs a new
X500PrincipalDatainstance using aPrincipalDataobject. - X500PrincipalData(String) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.X500PrincipalData
-
Constructs a new
X500PrincipalDatainstance with the specified name.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form