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

Class A2AModelInvoker

java.lang.Object

com.flowable.agent.engine.impl.model.a2a.A2AModelInvoker

All Implemented Interfaces:

AiModelInvoker

public class A2AModelInvoker
extends Object
implements AiModelInvoker

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
static final String	A2A_CONTEXT_SCOPE
protected AgentEngineConfiguration	agentEngineConfiguration
protected FlowableAuthenticationApiKey	authenticationApiKey
protected A2AClient	client

Constructor Summary

Constructors

Constructor	Description
A2AModelInvoker(AgentEngineConfiguration agentEngineConfiguration, A2AClient client, FlowableAuthenticationApiKey authenticationApiKey)

Method Summary

Modifier and Type	Method	Description
protected com.fasterxml.jackson.databind.node.ObjectNode	createArtifactDetailsNode(Artifact artifact)
protected com.fasterxml.jackson.databind.node.ObjectNode	createDataObjectNode(DataPart dataPart)
protected com.fasterxml.jackson.databind.node.ObjectNode	createFileObjectNode(FilePart filePart)
protected A2AAgentInvocationResultResponse	createInvocationResultResponseAndAddToExchange(A2AEvent response, boolean hasOutputSchema, AgentInvocationResultResponse.Exchange exchange, AgentInvocationResultResponse.Invocation invocation)
protected AgentInvocationResult	createResultFromPart(Part part, boolean hasOutputSchema)
protected A2AMessage	createSendMessage(AgentInvocationContext agentInvocationContext)
protected Map<String,String>	determineAdditionalHeaders(String tenantId)
protected Map<String,Object>	determineMetadata(AgentInvocationContext agentInvocationContext)
protected Part	findResultPartAndAddPartsToExchange(String partType, List<Part> parts, AgentInvocationResultResponse.Exchange exchange)
protected Part	getResultPartAndAddMessageToExchange(A2AMessage message, String partType, AgentInvocationResultResponse.Exchange exchange)
protected Part	getResultPartAndAddTaskToExchange(A2ATask task, AgentInvocationResultResponse.Exchange exchange)
A2AAgentInvocationResultResponse	getTask(String taskId, String tenantId, boolean hasOutputSchema)
AgentInvocationResultResponse	invoke(AgentInvocationContext agentInvocationContext)

Methods inherited from class java.lang.Object

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

Field Details

A2A_CONTEXT_SCOPE

public static final String A2A_CONTEXT_SCOPE

See Also:

• Constant Field Values

agentEngineConfiguration

protected AgentEngineConfiguration agentEngineConfiguration

client

protected A2AClient client

authenticationApiKey

protected FlowableAuthenticationApiKey authenticationApiKey

Constructor Details

A2AModelInvoker

public A2AModelInvoker(AgentEngineConfiguration agentEngineConfiguration,
 A2AClient client,
 FlowableAuthenticationApiKey authenticationApiKey)

Method Details

invoke

public AgentInvocationResultResponse invoke(AgentInvocationContext agentInvocationContext)

Specified by:

invoke in interface AiModelInvoker

createInvocationResultResponseAndAddToExchange

protected A2AAgentInvocationResultResponse createInvocationResultResponseAndAddToExchange(A2AEvent response,
 boolean hasOutputSchema,
 AgentInvocationResultResponse.Exchange exchange,
 AgentInvocationResultResponse.Invocation invocation)

createSendMessage

protected A2AMessage createSendMessage(AgentInvocationContext agentInvocationContext)

determineMetadata

protected Map<String,Object> determineMetadata(AgentInvocationContext agentInvocationContext)

getResultPartAndAddMessageToExchange

protected Part getResultPartAndAddMessageToExchange(A2AMessage message,
 String partType,
 AgentInvocationResultResponse.Exchange exchange)

createResultFromPart

protected AgentInvocationResult createResultFromPart(Part part,
 boolean hasOutputSchema)

findResultPartAndAddPartsToExchange

protected Part findResultPartAndAddPartsToExchange(String partType,
 List<Part> parts,
 AgentInvocationResultResponse.Exchange exchange)

createFileObjectNode

protected com.fasterxml.jackson.databind.node.ObjectNode createFileObjectNode(FilePart filePart)

createDataObjectNode

protected com.fasterxml.jackson.databind.node.ObjectNode createDataObjectNode(DataPart dataPart)

createArtifactDetailsNode

protected com.fasterxml.jackson.databind.node.ObjectNode createArtifactDetailsNode(Artifact artifact)

getResultPartAndAddTaskToExchange

protected Part getResultPartAndAddTaskToExchange(A2ATask task,
 AgentInvocationResultResponse.Exchange exchange)

determineAdditionalHeaders

protected Map<String,String> determineAdditionalHeaders(String tenantId)

getTask

public A2AAgentInvocationResultResponse getTask(String taskId,
 String tenantId,
 boolean hasOutputSchema)