Class AgentExecutorProducer

java.lang.Object

org.a2aproject.sdk.examples.streamlifecycle.server.AgentExecutorProducer

@ApplicationScoped
public class AgentExecutorProducer
extends Object

Agent executor that sends a series of messages over time, giving clients time to subscribe.

The agent sends 20 progress messages, one every 500ms. This gives the demo client enough time to establish multiple subscriptions and observe events flowing to each subscriber before the CloseStreamsHook closes all streams.

Constructor Summary

Constructors

Constructor	Description
AgentExecutorProducer()

Method Summary

Modifier and Type	Method	Description
AgentExecutor	agentExecutor()

Methods inherited from class Object

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

Constructor Details

AgentExecutorProducer

public AgentExecutorProducer()

Method Details

agentExecutor

@Produces
public AgentExecutor agentExecutor()