Package com.axelor.ai.chat.provider

Class LangChain4jChatProvider

java.lang.Object

com.axelor.ai.chat.provider.LangChain4jChatProvider

All Implemented Interfaces:

ChatProvider

public class LangChain4jChatProvider
extends Object
implements ChatProvider

Adapts a LangChain4j StreamingChatModel to the ChatProvider interface.

Converts UIMessage history to LangChain4j message types, streams the response via ChatProvider.Listener callbacks, and blocks until the LLM finishes.

Nested Class Summary

Nested classes/interfaces inherited from interface com.axelor.ai.chat.ChatProvider

ChatProvider.Listener

Field Summary

Fields

Modifier and Type	Field	Description
static final Duration	DEFAULT_SILENCE	How long a model may send nothing when its own timeout does not say.

Constructor Summary

Constructors

Constructor	Description
LangChain4jChatProvider(dev.langchain4j.model.chat.StreamingChatModel model, List<dev.langchain4j.agent.tool.ToolSpecification> toolSpecs, String modelCode, String providerCode, Integer rateLimit, AiRateLimiter rateLimiter, Duration silence)

Method Summary

Modifier and Type	Method	Description
void	stream(List<UIMessage> messages, ChatProvider.Listener listener)	Sends the conversation history to the LLM and streams the response back via the listener.

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_SILENCE

public static final Duration DEFAULT_SILENCE

How long a model may send nothing when its own timeout does not say.

Constructor Details

LangChain4jChatProvider

public LangChain4jChatProvider(dev.langchain4j.model.chat.StreamingChatModel model,
 List<dev.langchain4j.agent.tool.ToolSpecification> toolSpecs,
 String modelCode,
 String providerCode,
 Integer rateLimit,
 AiRateLimiter rateLimiter,
 Duration silence)

Parameters:

silence - how long the call may send nothing before it is given up; a call that keeps writing, a long reasoning one included, runs for as long as it writes

Method Details

stream

public void stream(List<UIMessage> messages,
 ChatProvider.Listener listener)

Description copied from interface: ChatProvider

Sends the conversation history to the LLM and streams the response back via the listener.

Implementations must call ChatProvider.Listener.onFinish(com.axelor.ai.chat.ChatResult) exactly once, after all content callbacks. This method blocks until the LLM response is fully consumed.

Specified by:

stream in interface ChatProvider

Parameters:

messages - the conversation history to send

listener - receives streaming deltas and the finish signal