Package io.jmix.dynmodelai.concurrent

Class ConversationCommands

java.lang.Object

io.jmix.dynmodelai.concurrent.ConversationCommands

@Component("dmagent_ConversationCommands")
public class ConversationCommands
extends Object

Serializes Conversation operations on a shared pool; native model calls never run here.

Constructor Summary

Constructors

Constructor	Description
ConversationCommands(Executor delegate)

Method Summary

Modifier and Type	Method	Description
<T> T	call(UUID conversationId, Supplier<T> operation)	Synchronous Java boundary.
void	run(UUID conversationId, Runnable operation)
<T extends @Nullable Object> CompletableFuture<T>	submit(UUID conversationId, Supplier<T> operation)	Always enqueues, including from a command: Close already in the queue precedes a new Launch.

Methods inherited from class java.lang.Object

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

Constructor Details

ConversationCommands

public ConversationCommands(@Qualifier("dmagent_ConversationExecutor")
 Executor delegate)

Method Details

submit

public <T extends @Nullable Object>
CompletableFuture<T> submit(UUID conversationId,
 Supplier<T> operation)

Always enqueues, including from a command: Close already in the queue precedes a new Launch.

call

public <T> T call(UUID conversationId,
 Supplier<T> operation)

Synchronous Java boundary. Calls between services within the same command execute inline.

run

public void run(UUID conversationId,
 Runnable operation)