Uses of Class
io.a2a.server.events.EventQueue
Packages that use EventQueue
-
Uses of EventQueue in io.a2a.server.events
Methods in io.a2a.server.events that return EventQueueModifier and TypeMethodDescriptionEventQueue.EventQueueBuilder.build()Builds and returns the configured EventQueue.InMemoryQueueManager.createOrTap(String taskId) QueueManager.createOrTap(String taskId) Creates a MainQueue if none exists, or taps the existing queue to create a ChildQueue.@Nullable EventQueue@Nullable EventQueueRetrieves the MainQueue for a task, if it exists.abstract EventQueueEventQueue.tap()Creates a child queue that shares events with this queue.@Nullable EventQueue@Nullable EventQueueCreates a ChildQueue that receives copies of events from the MainQueue.Methods in io.a2a.server.events with parameters of type EventQueueModifier and TypeMethodDescriptionvoidInMemoryQueueManager.add(String taskId, EventQueue queue) voidQueueManager.add(String taskId, EventQueue queue) Adds a queue to the manager with the given task ID.voidInMemoryQueueManager.awaitQueuePollerStart(EventQueue eventQueue) voidQueueManager.awaitQueuePollerStart(EventQueue eventQueue) Waits for the queue's consumer polling to start.Constructors in io.a2a.server.events with parameters of type EventQueueModifierConstructorDescriptionEventConsumer(EventQueue queue) protectedEventQueue(EventQueue parent) Creates an EventQueue as a child of the specified parent queue. -
Uses of EventQueue in io.a2a.server.tasks
Constructors in io.a2a.server.tasks with parameters of type EventQueueModifierConstructorDescriptionAgentEmitter(RequestContext context, EventQueue eventQueue) Creates a new AgentEmitter for the given request context and event queue.