Package io.a2a.server.requesthandlers

Class JSONRPCHandler

java.lang.Object

io.a2a.server.requesthandlers.JSONRPCHandler

@ApplicationScoped
public class JSONRPCHandler
extends Object

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JSONRPCHandler()
	JSONRPCHandler(AgentCard agentCard, RequestHandler requestHandler)

Method Summary

Modifier and Type	Method	Description
AgentCard	getAgentCard()
GetTaskPushNotificationConfigResponse	getPushNotification(GetTaskPushNotificationConfigRequest request)
CancelTaskResponse	onCancelTask(CancelTaskRequest request)
GetTaskResponse	onGetTask(GetTaskRequest request)
SendMessageResponse	onMessageSend(SendMessageRequest request)
Flow.Publisher<SendStreamingMessageResponse>	onMessageSendStream(SendStreamingMessageRequest request)
Flow.Publisher<SendStreamingMessageResponse>	onResubscribeToTask(TaskResubscriptionRequest request)
SetTaskPushNotificationConfigResponse	setPushNotification(SetTaskPushNotificationConfigRequest request)

Methods inherited from class java.lang.Object

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

Constructor Details

JSONRPCHandler

protected JSONRPCHandler()

JSONRPCHandler

@Inject
public JSONRPCHandler(AgentCard agentCard,
 RequestHandler requestHandler)

Method Details

onMessageSend

public SendMessageResponse onMessageSend(SendMessageRequest request)

onMessageSendStream

public Flow.Publisher<SendStreamingMessageResponse> onMessageSendStream(SendStreamingMessageRequest request)

onCancelTask

public CancelTaskResponse onCancelTask(CancelTaskRequest request)

onResubscribeToTask

public Flow.Publisher<SendStreamingMessageResponse> onResubscribeToTask(TaskResubscriptionRequest request)

getPushNotification

public GetTaskPushNotificationConfigResponse getPushNotification(GetTaskPushNotificationConfigRequest request)

setPushNotification

public SetTaskPushNotificationConfigResponse setPushNotification(SetTaskPushNotificationConfigRequest request)

onGetTask

public GetTaskResponse onGetTask(GetTaskRequest request)

getAgentCard

public AgentCard getAgentCard()