Uses of Class
org.a2aproject.sdk.server.events.EventQueue

Packages that use EventQueue

Package	Description
org.a2aproject.sdk.extras.queuemanager.replicated.core
org.a2aproject.sdk.server.events
org.a2aproject.sdk.server.tasks

Uses of EventQueue in org.a2aproject.sdk.extras.queuemanager.replicated.core

Methods in org.a2aproject.sdk.extras.queuemanager.replicated.core that return EventQueue

Modifier and Type	Method	Description
EventQueue	ReplicatedQueueManager.createOrTap(String taskId)
EventQueue	ReplicatedQueueManager.get(String taskId)
EventQueue	ReplicatedQueueManager.tap(String taskId)

Methods in org.a2aproject.sdk.extras.queuemanager.replicated.core with parameters of type EventQueue

Modifier and Type	Method	Description
void	ReplicatedQueueManager.add(String taskId, EventQueue queue)
void	ReplicatedQueueManager.awaitQueuePollerStart(EventQueue eventQueue)

Uses of EventQueue in org.a2aproject.sdk.server.events

Methods in org.a2aproject.sdk.server.events that return EventQueue

Modifier and Type	Method	Description
EventQueue	EventQueue.EventQueueBuilder.build()	Builds and returns the configured EventQueue.
EventQueue	InMemoryQueueManager.createOrTap(String taskId)
EventQueue	QueueManager.createOrTap(String taskId)	Creates a MainQueue if none exists, or taps the existing queue to create a ChildQueue.
@Nullable EventQueue	InMemoryQueueManager.get(String taskId)
@Nullable EventQueue	QueueManager.get(String taskId)	Retrieves the MainQueue for a task, if it exists.
abstract EventQueue	EventQueue.tap()	Creates a child queue that shares events with this queue.
@Nullable EventQueue	InMemoryQueueManager.tap(String taskId)
@Nullable EventQueue	QueueManager.tap(String taskId)	Creates a ChildQueue that receives copies of events from the MainQueue.

Methods in org.a2aproject.sdk.server.events with parameters of type EventQueue

Modifier and Type	Method	Description
void	InMemoryQueueManager.add(String taskId, EventQueue queue)
void	QueueManager.add(String taskId, EventQueue queue)	Adds a queue to the manager with the given task ID.
void	InMemoryQueueManager.awaitQueuePollerStart(EventQueue eventQueue)
void	QueueManager.awaitQueuePollerStart(EventQueue eventQueue)	Waits for the queue's consumer polling to start.

Constructors in org.a2aproject.sdk.server.events with parameters of type EventQueue

Modifier	Constructor	Description
	EventConsumer(EventQueue queue, Executor executor)
protected	EventQueue(EventQueue parent)	Creates an EventQueue as a child of the specified parent queue.

Uses of EventQueue in org.a2aproject.sdk.server.tasks

Constructors in org.a2aproject.sdk.server.tasks with parameters of type EventQueue

Modifier	Constructor	Description
	AgentEmitter(RequestContext context, EventQueue eventQueue)	Creates a new AgentEmitter for the given request context and event queue.