Package io.a2a.server.events

Interface QueueManager

All Known Implementing Classes:

InMemoryQueueManager

public interface QueueManager

Method Summary

Modifier and Type	Method	Description
void	add(String taskId, EventQueue queue)
void	awaitQueuePollerStart(EventQueue eventQueue)
void	close(String taskId)
EventQueue	createOrTap(String taskId)
EventQueue	get(String taskId)
int	getActiveChildQueueCount(String taskId)	Get the count of active child queues for a given task.
default EventQueue.EventQueueBuilder	getEventQueueBuilder(String taskId)
EventQueue	tap(String taskId)

Method Details

add

void add(String taskId,
 EventQueue queue)

get

EventQueue get(String taskId)

tap

EventQueue tap(String taskId)

close

void close(String taskId)

createOrTap

EventQueue createOrTap(String taskId)

awaitQueuePollerStart

void awaitQueuePollerStart(EventQueue eventQueue)
                    throws InterruptedException

Throws:

InterruptedException

getEventQueueBuilder

default EventQueue.EventQueueBuilder getEventQueueBuilder(String taskId)

getActiveChildQueueCount

int getActiveChildQueueCount(String taskId)

Get the count of active child queues for a given task. Used for testing to verify reference counting mechanism.

Parameters:

taskId - the task ID

Returns:

number of active child queues, or -1 if queue doesn't exist