Index

A B C D E F G H I J L M N O P R S T U V X 
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 X509Certificate AlternativeName class.
AlternativeNameData(int, String) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.AlternativeNameData
Constructs a new AlternativeNameData instance 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 CertificateData instance 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 CertificateData instance 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 X509Extension package.
CertificateExtension(String, boolean, byte[], String) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.CertificateExtension
Constructs a new CertificateExtension instance 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 events record 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 finalEventFound record 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 A2AErrorTypes from a given Throwable, 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 originalAttributes record 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 Principal class.
PrincipalData(String) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.PrincipalData
Constructs a new PrincipalData instance 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 PublicKey class.
PublicKeyData(String, byte[]) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.PublicKeyData
Constructs a new PublicKeyData instance 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 PublicKeyData instance 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 responseAttributes record 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 Certificate SerialNumber class.
SerialNumberData(BigInteger) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.SerialNumberData
Constructs a new SerialNumberData instance 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 SseConnectionResult record 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 SseSessionResult record class.
sseSource() - Method in record class com.mulesoft.connectors.a2a.internal.client.model.SseConnectionResult
Returns the value of the sseSource record 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 Principal X509Principal class.
X500PrincipalData(PrincipalData) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.X500PrincipalData
Constructs a new X500PrincipalData instance using a PrincipalData object.
X500PrincipalData(String) - Constructor for class com.mulesoft.connectors.a2a.api.certificate.X500PrincipalData
Constructs a new X500PrincipalData instance with the specified name.
A B C D E F G H I J L M N O P R S T U V X 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form