Package io.jmix.dynmodelai.session

Class AgentEventStreams

java.lang.Object

io.jmix.dynmodelai.session.AgentEventStreams

@Component("dmagent_AgentEventStreams")
public class AgentEventStreams
extends Object

Transport only. Pending questions and Run transitions belong to Conversation commands.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_EVENTS_PER_RUN

Constructor Summary

Constructors

Constructor	Description
AgentEventStreams(ConversationCommands commands, Messages messages, AgentHistory history, ConversationSessions sessions)

Method Summary

Modifier and Type	Method	Description
boolean	completeRun(UUID conversationId, UUID runId, String summary, @Nullable String detail, RunOutcome outcome)
boolean	completeRun(UUID conversationId, UUID runId, String summary, @Nullable String detail, RunOutcome outcome, @Nullable DraftPresentation draft)
void	failRun(UUID conversationId, UUID runId, RuntimeException failure)	Terminates transport after a failed mandatory write; no replacement history is invented.
void	observe(UUID conversationId, UUID runId, AgentObservation observation)	Saves diagnostics once, then emits only their safe progress projection, with an independent cursor.
AgentEvent	publish(UUID conversationId, UUID runId, AgentEventPayload payload)
void	registerRun(UUID conversationId, UUID runId)
void	releaseRun(UUID runId)	Release transport retention after the owning Conversation resolves or expires its question.
reactor.core.publisher.Flux<AgentEvent>	streamEvents(UUID conversationId, UUID runId, long afterSequence)

Methods inherited from class java.lang.Object

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

Field Details

MAX_EVENTS_PER_RUN

public static final int MAX_EVENTS_PER_RUN

See Also:

• Constant Field Values

Constructor Details

AgentEventStreams

public AgentEventStreams(ConversationCommands commands,
 Messages messages,
 AgentHistory history,
 ConversationSessions sessions)

Method Details

registerRun

public void registerRun(UUID conversationId,
 UUID runId)

publish

public AgentEvent publish(UUID conversationId,
 UUID runId,
 AgentEventPayload payload)

observe

public void observe(UUID conversationId,
 UUID runId,
 AgentObservation observation)

Saves diagnostics once, then emits only their safe progress projection, with an independent cursor.

completeRun

public boolean completeRun(UUID conversationId,
 UUID runId,
 String summary,
 @Nullable String detail,
 RunOutcome outcome)

completeRun

public boolean completeRun(UUID conversationId,
 UUID runId,
 String summary,
 @Nullable String detail,
 RunOutcome outcome,
 @Nullable DraftPresentation draft)

failRun

public void failRun(UUID conversationId,
 UUID runId,
 RuntimeException failure)

Terminates transport after a failed mandatory write; no replacement history is invented.

releaseRun

public void releaseRun(UUID runId)

Release transport retention after the owning Conversation resolves or expires its question.

streamEvents

public reactor.core.publisher.Flux<AgentEvent> streamEvents(UUID conversationId,
 UUID runId,
 long afterSequence)