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

Class RestA2AClient

java.lang.Object

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

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

All Implemented Interfaces:

A2AClient

public class RestA2AClient
extends BaseA2AClient

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected final com.fasterxml.jackson.databind.ObjectMapper	objectMapper

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

restClient, TASK_NOT_FOUND_ERROR_CODE

Constructor Summary

Constructors

Constructor	Description
RestA2AClient(RestClient restClient, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
protected <T> T	executeRequest(RestClient.RequestHeadersSpec<?> spec, String operation, Class<T> clazz, boolean allowTaskNotFound, Map<String,String> additionalHeaders)
A2ATask	getTask(String taskId, Map<String,String> additionalHeaders)
protected <T> T	handleResponse(ResponseEntity<String> response, Class<T> clazz, String operation, boolean allowTaskNotFound)
protected <T> T	readValue(String body, Class<T> clazz)
A2AEvent	sendMessage(A2AMessage message, Map<String,String> additionalHeaders)

Methods inherited from class java.lang.Object

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

Field Details

objectMapper

protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper

Constructor Details

RestA2AClient

public RestA2AClient(RestClient restClient,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Details

sendMessage

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

getTask

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

executeRequest

protected <T> T executeRequest(RestClient.RequestHeadersSpec<?> spec,
 String operation,
 Class<T> clazz,
 boolean allowTaskNotFound,
 Map<String,String> additionalHeaders)

handleResponse

protected <T> T handleResponse(ResponseEntity<String> response,
 Class<T> clazz,
 String operation,
 boolean allowTaskNotFound)

readValue

protected <T> T readValue(String body,
 Class<T> clazz)