Package io.a2a.server.requesthandlers

Class DefaultRequestHandler

java.lang.Object

io.a2a.server.requesthandlers.DefaultRequestHandler

All Implemented Interfaces:

RequestHandler

@ApplicationScoped
public class DefaultRequestHandler
extends Object
implements RequestHandler

Constructor Summary

Constructors

Constructor	Description
DefaultRequestHandler(AgentExecutor agentExecutor, TaskStore taskStore, QueueManager queueManager, PushNotificationConfigStore pushConfigStore, PushNotificationSender pushSender, Executor executor)

Method Summary

Modifier and Type	Method	Description
static DefaultRequestHandler	create(AgentExecutor agentExecutor, TaskStore taskStore, QueueManager queueManager, PushNotificationConfigStore pushConfigStore, PushNotificationSender pushSender, Executor executor)	For testing
Task	onCancelTask(TaskIdParams params, ServerCallContext context)
void	onDeleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigParams params, ServerCallContext context)
Task	onGetTask(TaskQueryParams params, ServerCallContext context)
TaskPushNotificationConfig	onGetTaskPushNotificationConfig(GetTaskPushNotificationConfigParams params, ServerCallContext context)
List<TaskPushNotificationConfig>	onListTaskPushNotificationConfig(ListTaskPushNotificationConfigParams params, ServerCallContext context)
EventKind	onMessageSend(MessageSendParams params, ServerCallContext context)
Flow.Publisher<StreamingEventKind>	onMessageSendStream(MessageSendParams params, ServerCallContext context)
Flow.Publisher<StreamingEventKind>	onResubscribeToTask(TaskIdParams params, ServerCallContext context)
TaskPushNotificationConfig	onSetTaskPushNotificationConfig(TaskPushNotificationConfig params, ServerCallContext context)
CompletableFuture<Void>	waitForBackgroundTasks()	Wait for all background tasks to complete.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultRequestHandler

@Inject
public DefaultRequestHandler(AgentExecutor agentExecutor,
 TaskStore taskStore,
 QueueManager queueManager,
 PushNotificationConfigStore pushConfigStore,
 PushNotificationSender pushSender,
 Executor executor)

Method Details

create

public static DefaultRequestHandler create(AgentExecutor agentExecutor,
 TaskStore taskStore,
 QueueManager queueManager,
 PushNotificationConfigStore pushConfigStore,
 PushNotificationSender pushSender,
 Executor executor)

For testing

onGetTask

public Task onGetTask(TaskQueryParams params,
 ServerCallContext context)
               throws JSONRPCError

Specified by:

onGetTask in interface RequestHandler

Throws:

JSONRPCError

onCancelTask

public Task onCancelTask(TaskIdParams params,
 ServerCallContext context)
                  throws JSONRPCError

Specified by:

onCancelTask in interface RequestHandler

Throws:

JSONRPCError

onMessageSend

public EventKind onMessageSend(MessageSendParams params,
 ServerCallContext context)
                        throws JSONRPCError

Specified by:

onMessageSend in interface RequestHandler

Throws:

JSONRPCError

onMessageSendStream

public Flow.Publisher<StreamingEventKind> onMessageSendStream(MessageSendParams params,
 ServerCallContext context)
                                                       throws JSONRPCError

Specified by:

onMessageSendStream in interface RequestHandler

Throws:

JSONRPCError

onSetTaskPushNotificationConfig

public TaskPushNotificationConfig onSetTaskPushNotificationConfig(TaskPushNotificationConfig params,
 ServerCallContext context)
                                                           throws JSONRPCError

Specified by:

onSetTaskPushNotificationConfig in interface RequestHandler

Throws:

JSONRPCError

onGetTaskPushNotificationConfig

public TaskPushNotificationConfig onGetTaskPushNotificationConfig(GetTaskPushNotificationConfigParams params,
 ServerCallContext context)
                                                           throws JSONRPCError

Specified by:

onGetTaskPushNotificationConfig in interface RequestHandler

Throws:

JSONRPCError

onResubscribeToTask

public Flow.Publisher<StreamingEventKind> onResubscribeToTask(TaskIdParams params,
 ServerCallContext context)
                                                       throws JSONRPCError

Specified by:

onResubscribeToTask in interface RequestHandler

Throws:

JSONRPCError

onListTaskPushNotificationConfig

public List<TaskPushNotificationConfig> onListTaskPushNotificationConfig(ListTaskPushNotificationConfigParams params,
 ServerCallContext context)
                                                                  throws JSONRPCError

Specified by:

onListTaskPushNotificationConfig in interface RequestHandler

Throws:

JSONRPCError

onDeleteTaskPushNotificationConfig

public void onDeleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigParams params,
 ServerCallContext context)

Specified by:

onDeleteTaskPushNotificationConfig in interface RequestHandler

waitForBackgroundTasks

public CompletableFuture<Void> waitForBackgroundTasks()

Wait for all background tasks to complete. Useful for testing to ensure cleanup completes before assertions.

Returns:

CompletableFuture that completes when all background tasks finish