Package com.alibaba.cloud.ai.graph.agent

Class ReactAgent

java.lang.Object

com.alibaba.cloud.ai.graph.agent.Agent

com.alibaba.cloud.ai.graph.agent.BaseAgent

com.alibaba.cloud.ai.graph.agent.ReactAgent

public class ReactAgent
extends BaseAgent

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ReactAgent.AgentToSubCompiledGraphNodeAdapter

Field Summary

Fields inherited from class com.alibaba.cloud.ai.graph.agent.BaseAgent

includeContents, inputSchema, inputType, outputKey, outputKeyStrategy, outputSchema, outputType, returnReasoningContents

Fields inherited from class com.alibaba.cloud.ai.graph.agent.Agent

compileConfig, compiledGraph, description, executor, graph, name

Constructor Summary

Constructors

Constructor	Description
ReactAgent(AgentLlmNode llmNode, AgentToolNode toolNode, CompileConfig compileConfig, Builder builder)

Method Summary

Modifier and Type	Method	Description
Node	asNode(boolean includeContents, boolean returnReasoningContents)
static Builder	builder()
static Builder	builder(AgentBuilderFactory agentBuilderFactory)
org.springframework.ai.chat.messages.AssistantMessage	call(String message)
org.springframework.ai.chat.messages.AssistantMessage	call(String message, RunnableConfig config)
org.springframework.ai.chat.messages.AssistantMessage	call(List<org.springframework.ai.chat.messages.Message> messages)
org.springframework.ai.chat.messages.AssistantMessage	call(List<org.springframework.ai.chat.messages.Message> messages, RunnableConfig config)
org.springframework.ai.chat.messages.AssistantMessage	call(org.springframework.ai.chat.messages.UserMessage message)
org.springframework.ai.chat.messages.AssistantMessage	call(org.springframework.ai.chat.messages.UserMessage message, RunnableConfig config)
CompiledGraph	getCompiledGraph()
StateGraph	getStateGraph()
Map<String,Object>	getThreadState(String threadId)
protected StateGraph	initGraph()
String	instruction()
void	interrupt(RunnableConfig config)
void	interrupt(String userMessage, RunnableConfig config)
void	interrupt(List<org.springframework.ai.chat.messages.Message> messages, RunnableConfig config)
void	setInstruction(String instruction)
void	updateAgentState(Object state, RunnableConfig config)	Updates the agent thread state with interruption feedback.

Methods inherited from class com.alibaba.cloud.ai.graph.agent.BaseAgent

getOutputKey, getOutputKeyStrategy, isIncludeContents, isReturnReasoningContents, setOutputKey, setOutputKeyStrategy, setReturnReasoningContents

Methods inherited from class com.alibaba.cloud.ai.graph.agent.Agent

applyExecutorConfig, buildMessageInput, buildNonStreamConfig, buildStreamConfig, description, doInvoke, doInvokeAndGetOutput, doStream, getAndCompileGraph, getCurrentState, getGraph, invoke, invoke, invoke, invoke, invoke, invoke, invokeAndGetOutput, invokeAndGetOutput, invokeAndGetOutput, invokeAndGetOutput, invokeAndGetOutput, invokeAndGetOutput, name, schedule, schedule, stream, stream, stream, stream, stream, stream

Methods inherited from class java.lang.Object

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

Constructor Details

ReactAgent

public ReactAgent(AgentLlmNode llmNode,
 AgentToolNode toolNode,
 CompileConfig compileConfig,
 Builder builder)

Method Details

builder

public static Builder builder()

builder

public static Builder builder(AgentBuilderFactory agentBuilderFactory)

call

public org.springframework.ai.chat.messages.AssistantMessage call(String message)
                                                           throws GraphRunnerException

Throws:

GraphRunnerException

call

public org.springframework.ai.chat.messages.AssistantMessage call(String message,
 RunnableConfig config)
                                                           throws GraphRunnerException

Throws:

GraphRunnerException

call

public org.springframework.ai.chat.messages.AssistantMessage call(org.springframework.ai.chat.messages.UserMessage message)
                                                           throws GraphRunnerException

Throws:

GraphRunnerException

call

public org.springframework.ai.chat.messages.AssistantMessage call(org.springframework.ai.chat.messages.UserMessage message,
 RunnableConfig config)
                                                           throws GraphRunnerException

Throws:

GraphRunnerException

call

public org.springframework.ai.chat.messages.AssistantMessage call(List<org.springframework.ai.chat.messages.Message> messages)
                                                           throws GraphRunnerException

Throws:

GraphRunnerException

call

public org.springframework.ai.chat.messages.AssistantMessage call(List<org.springframework.ai.chat.messages.Message> messages,
 RunnableConfig config)
                                                           throws GraphRunnerException

Throws:

GraphRunnerException

interrupt

public void interrupt(RunnableConfig config)

interrupt

public void interrupt(List<org.springframework.ai.chat.messages.Message> messages,
 RunnableConfig config)

interrupt

public void interrupt(String userMessage,
 RunnableConfig config)

updateAgentState

public void updateAgentState(Object state,
 RunnableConfig config)

Updates the agent thread state with interruption feedback. This method is thread-safe and can be called concurrently with apply() in InterruptionHook. Thread-safety guarantees: - threadIdStateMap is a ConcurrentHashMap, ensuring thread-safe access - computeIfAbsent ensures atomic creation of the inner map if it doesn't exist - The inner map is always a ConcurrentHashMap, ensuring thread-safe put() operations Concurrency behavior: - If called before apply() processes feedback: the new value will be processed - If called after apply() removes feedback: the new value will be set for next iteration - If called concurrently with apply(): the atomic operations ensure no data loss

getStateGraph

public StateGraph getStateGraph()

getCompiledGraph

public CompiledGraph getCompiledGraph()

asNode

public Node asNode(boolean includeContents,
 boolean returnReasoningContents)

Specified by:

asNode in class BaseAgent

initGraph

protected StateGraph initGraph()
                        throws GraphStateException

Specified by:

initGraph in class Agent

Throws:

GraphStateException

instruction

public String instruction()

setInstruction

public void setInstruction(String instruction)

getThreadState

public Map<String,Object> getThreadState(String threadId)