Class InMemoryChatMemoryStore

java.lang.Object

dev.langchain4j.store.memory.chat.InMemoryChatMemoryStore

All Implemented Interfaces:

ChatMemoryStore

public class InMemoryChatMemoryStore
extends Object
implements ChatMemoryStore

Implementation of ChatMemoryStore that stores state of ChatMemory (chat messages) in-memory.

This storage mechanism is transient and does not persist data across application restarts.

Constructor Summary

Constructors

Constructor	Description
InMemoryChatMemoryStore()	Constructs a new InMemoryChatMemoryStore.

Method Summary

Modifier and Type	Method	Description
void	deleteMessages(Object memoryId)	Deletes all messages for a specified chat memory.
CompletableFuture<Void>	deleteMessagesAsync(Object memoryId)	Non-blocking counterpart of ChatMemoryStore.deleteMessages(Object), used by the asynchronous (CompletableFuture/CompletionStage) and reactive (Flow.Publisher) AI Service APIs.
List<ChatMessage>	getMessages(Object memoryId)	Retrieves messages for a specified chat memory.
CompletableFuture<List<ChatMessage>>	getMessagesAsync(Object memoryId)	Non-blocking counterpart of ChatMemoryStore.getMessages(Object), used by the asynchronous (CompletableFuture/CompletionStage) and reactive (Flow.Publisher) AI Service APIs.
void	updateMessages(Object memoryId, List<ChatMessage> messages)	Updates messages for a specified chat memory.
CompletableFuture<Void>	updateMessagesAsync(Object memoryId, List<ChatMessage> messages)	Non-blocking counterpart of ChatMemoryStore.updateMessages(Object, List), used by the asynchronous (CompletableFuture/CompletionStage) and reactive (Flow.Publisher) AI Service APIs.

Methods inherited from class Object

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

Constructor Details

InMemoryChatMemoryStore

public InMemoryChatMemoryStore()

Constructs a new InMemoryChatMemoryStore.

Method Details

getMessages

public List<ChatMessage> getMessages(Object memoryId)

Description copied from interface: ChatMemoryStore

Retrieves messages for a specified chat memory.

Specified by:

getMessages in interface ChatMemoryStore

Parameters:

memoryId - The ID of the chat memory.

Returns:

List of messages for the specified chat memory. Must not be null. Can be deserialized from JSON using ChatMessageDeserializer.

updateMessages

public void updateMessages(Object memoryId,
 List<ChatMessage> messages)

Description copied from interface: ChatMemoryStore

Updates messages for a specified chat memory.

Specified by:

updateMessages in interface ChatMemoryStore

Parameters:

memoryId - The ID of the chat memory.

messages - List of messages for the specified chat memory, that represent the current state of the ChatMemory. Can be serialized to JSON using ChatMessageSerializer.

deleteMessages

public void deleteMessages(Object memoryId)

Description copied from interface: ChatMemoryStore

Deletes all messages for a specified chat memory.

Specified by:

deleteMessages in interface ChatMemoryStore

Parameters:

memoryId - The ID of the chat memory.

getMessagesAsync

public CompletableFuture<List<ChatMessage>> getMessagesAsync(Object memoryId)

Description copied from interface: ChatMemoryStore

Non-blocking counterpart of ChatMemoryStore.getMessages(Object), used by the asynchronous (CompletableFuture/CompletionStage) and reactive (Flow.Publisher) AI Service APIs.

The default implementation returns a failed future carrying AsyncNotSupportedException: a store backed by blocking I/O is not silently offloaded to a worker thread, because that would hide the fact that it is not truly non-blocking. Implement this method to return the messages without blocking the calling thread (e.g. using a reactive client), or, if the underlying client is blocking, offload it to an executor explicitly.

Specified by:

getMessagesAsync in interface ChatMemoryStore

Parameters:

memoryId - The ID of the chat memory.

Returns:

A future that completes with the list of messages for the specified chat memory. Must not be null.

updateMessagesAsync

public CompletableFuture<Void> updateMessagesAsync(Object memoryId,
 List<ChatMessage> messages)

Description copied from interface: ChatMemoryStore

Non-blocking counterpart of ChatMemoryStore.updateMessages(Object, List), used by the asynchronous (CompletableFuture/CompletionStage) and reactive (Flow.Publisher) AI Service APIs.

The default implementation returns a failed future carrying AsyncNotSupportedException; see ChatMemoryStore.getMessagesAsync(Object) for the rationale.

Specified by:

updateMessagesAsync in interface ChatMemoryStore

Parameters:

memoryId - The ID of the chat memory.

messages - List of messages for the specified chat memory, that represent the current state of the ChatMemory.

Returns:

A future that completes when the messages have been stored.

deleteMessagesAsync

public CompletableFuture<Void> deleteMessagesAsync(Object memoryId)

Description copied from interface: ChatMemoryStore

Non-blocking counterpart of ChatMemoryStore.deleteMessages(Object), used by the asynchronous (CompletableFuture/CompletionStage) and reactive (Flow.Publisher) AI Service APIs.

The default implementation returns a failed future carrying AsyncNotSupportedException; see ChatMemoryStore.getMessagesAsync(Object) for the rationale.

Specified by:

deleteMessagesAsync in interface ChatMemoryStore

Parameters:

memoryId - The ID of the chat memory.

Returns:

A future that completes when the messages have been deleted.