Package com.flowable.agent.engine.impl.model.a2a.client

Class JsonRpcA2AClient

java.lang.Object

com.flowable.agent.engine.impl.model.a2a.client.BaseA2AClient

com.flowable.agent.engine.impl.model.a2a.client.JsonRpcA2AClient

All Implemented Interfaces:

A2AClient

public class JsonRpcA2AClient
extends BaseA2AClient

Author:

Filip Hrisafov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JsonRpcA2AClient.JsonRpcRequest
static class	JsonRpcA2AClient.JsonRpcResponse<T>

Field Summary

Fields inherited from class com.flowable.agent.engine.impl.model.a2a.client.BaseA2AClient

restClient, TASK_NOT_FOUND_ERROR_CODE

Constructor Summary

Constructors

Constructor	Description
JsonRpcA2AClient(RestClient restClient)

Method Summary

Modifier and Type	Method	Description
A2ATask	getTask(String taskId, Map<String,String> additionalHeaders)
A2AEvent	sendMessage(A2AMessage message, Map<String,String> additionalHeaders)
protected <T> T	sendRequest(String method, Object params, ParameterizedTypeReference<JsonRpcA2AClient.JsonRpcResponse<T>> responseType, boolean allowTaskNotFound, Map<String,String> additionalHeaders)

Methods inherited from class java.lang.Object

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

Constructor Details

JsonRpcA2AClient

public JsonRpcA2AClient(RestClient restClient)

Method Details

sendMessage

public A2AEvent sendMessage(A2AMessage message,
 Map<String,String> additionalHeaders)

getTask

public A2ATask getTask(String taskId,
 Map<String,String> additionalHeaders)

sendRequest

protected <T> T sendRequest(String method,
 Object params,
 ParameterizedTypeReference<JsonRpcA2AClient.JsonRpcResponse<T>> responseType,
 boolean allowTaskNotFound,
 Map<String,String> additionalHeaders)