Uses of Class
com.mulesoft.connectors.a2a.internal.server.agent.sse.SseClientRegistry

Packages that use SseClientRegistry

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

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

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

Modifier and Type	Method	Description
SseClientRegistry	RequestHandlerContext.getSseClientRegistry()
SseClientRegistry	ServerAgent.getSseClientRegistry()

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

Modifier and Type	Method	Description
RequestHandlerContext.Builder	RequestHandlerContext.Builder.sseClientRegistry(SseClientRegistry sseClientRegistry)

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

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

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 SseClientRegistry in com.mulesoft.connectors.a2a.internal.server.agent.utils

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

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 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)