Package com.mulesoft.connectors.a2a.internal.server.agent.operations

Class TaskResubscribeHandler

java.lang.Object

com.mulesoft.connectors.a2a.internal.server.agent.operations.RequestHandler

com.mulesoft.connectors.a2a.internal.server.agent.operations.TaskResubscribeHandler

public class TaskResubscribeHandler
extends RequestHandler

Handler for tasks/resubscribe JSON-RPC method. Allows clients to reconnect to an existing SSE stream for ongoing tasks.

Constructor Summary

Constructors

Constructor	Description
TaskResubscribeHandler()

Method Summary

Modifier and Type	Method	Description
String	createResponseBody(RequestHandlerContext context, RpcRequestContext.Response response)
void	doExecute(RequestHandlerContext handlerContext)
protected TaskIdentifiers	getTaskIdentifiers(RequestHandlerContext context)
protected void	validate(RequestHandlerContext handlerContext, TaskRepositoryItem taskItem)

Methods inherited from class com.mulesoft.connectors.a2a.internal.server.agent.operations.RequestHandler

execute, setupResponseHandler, validateContext, validateTask

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TaskResubscribeHandler

public TaskResubscribeHandler()

Method Details

getTaskIdentifiers

protected TaskIdentifiers getTaskIdentifiers(RequestHandlerContext context)

Specified by:

getTaskIdentifiers in class RequestHandler

validate

protected void validate(RequestHandlerContext handlerContext,
 TaskRepositoryItem taskItem)

Specified by:

validate in class RequestHandler

doExecute

public void doExecute(RequestHandlerContext handlerContext)

Specified by:

doExecute in class RequestHandler

createResponseBody

public String createResponseBody(RequestHandlerContext context,
 RpcRequestContext.Response response)

Specified by:

createResponseBody in class RequestHandler