Uses of Interface
com.mulesoft.connectors.a2a.internal.server.agent.repository.TaskRepository

Packages that use TaskRepository

Package	Description
com.mulesoft.connectors.a2a.internal.server.agent
com.mulesoft.connectors.a2a.internal.server.agent.repository
com.mulesoft.connectors.a2a.internal.server.agent.sse
com.mulesoft.connectors.a2a.internal.server.agent.utils

Uses of TaskRepository in com.mulesoft.connectors.a2a.internal.server.agent

Methods in com.mulesoft.connectors.a2a.internal.server.agent that return TaskRepository

Modifier and Type	Method	Description
TaskRepository	RequestHandlerContext.getTaskRepository()
TaskRepository	ServerAgent.getTaskRepository()

Methods in com.mulesoft.connectors.a2a.internal.server.agent with parameters of type TaskRepository

Modifier and Type	Method	Description
protected void	ServerAgent.setTaskRepository(TaskRepository taskRepository)	Sets the task repository.
RequestHandlerContext.Builder	RequestHandlerContext.Builder.taskRepository(TaskRepository taskRepository)

Uses of TaskRepository in com.mulesoft.connectors.a2a.internal.server.agent.repository

Classes in com.mulesoft.connectors.a2a.internal.server.agent.repository that implement TaskRepository

Modifier and Type	Class	Description
class	DefaultTaskRepository	Default implementation of TaskRepository that manages task data and push notification configs.
class	NullTaskRepository

Constructors in com.mulesoft.connectors.a2a.internal.server.agent.repository with parameters of type TaskRepository

Modifier	Constructor	Description
	DefaultTaskStoreServiceImpl(TaskRepository taskRepository, A2ASerializer a2ASerializer)

Uses of TaskRepository in com.mulesoft.connectors.a2a.internal.server.agent.sse

Constructors in com.mulesoft.connectors.a2a.internal.server.agent.sse with parameters of type TaskRepository

Modifier	Constructor	Description
	CrossWorkerPoller(String taskId, org.mule.runtime.http.api.sse.server.SseClient client, TaskRepository repository, A2ASerializer a2ASerializer, SseClientRegistry sseClientRegistry, org.mule.runtime.api.scheduler.Scheduler scheduler)

Uses of TaskRepository in com.mulesoft.connectors.a2a.internal.server.agent.utils

Methods in com.mulesoft.connectors.a2a.internal.server.agent.utils with parameters of type TaskRepository

Modifier and Type	Method	Description
static void	SseUtils.broadcastEvent(String taskId, String eventType, io.a2a.spec.StreamingEventKind streamingEvent, TaskRepository taskRepository, A2ASerializer a2ASerializer, SseClientRegistry sseClientRegistry)	Broadcasts an SSE event to all clients for a specific task
static String	SseUtils.createStreamingResponse(String taskId, io.a2a.spec.StreamingEventKind streamingEvent, TaskRepository taskRepository)	Creates a JSON-RPC success response for SSE events
static List<TaskEvent>	SseUtils.getBufferedEvents(TaskRepository taskRepository, String taskId)	Gets buffered events for a task, returns empty list if none found
static void	SseUtils.handleClientFailure(String taskId, org.mule.runtime.http.api.sse.server.SseClient sseClient, TaskRepository taskRepository, A2ASerializer a2ASerializer, SseClientRegistry sseClientRegistry)	Handles client failure - sends failure event to the specific client.
static void	SseUtils.replayBufferedEventsToClient(List<TaskEvent> bufferedEvents, String taskId, org.mule.runtime.http.api.sse.server.SseClient sseClient, TaskRepository taskRepository, A2ASerializer a2ASerializer, SseClientRegistry sseClientRegistry)	Sends buffered events to a specific SSE client (for resubscribe scenarios)