Package io.a2a.server.events

Class InMemoryQueueManager

java.lang.Object

io.a2a.server.events.InMemoryQueueManager

All Implemented Interfaces:

QueueManager

@ApplicationScoped
public class InMemoryQueueManager
extends Object
implements QueueManager

Constructor Summary

Constructors

Constructor	Description
InMemoryQueueManager()
InMemoryQueueManager(EventQueueFactory factory)

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)
EventQueue	tap(String taskId)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.a2a.server.events.QueueManager

getEventQueueBuilder

Constructor Details

InMemoryQueueManager

public InMemoryQueueManager()

InMemoryQueueManager

public InMemoryQueueManager(EventQueueFactory factory)

Method Details

add

public void add(String taskId,
 EventQueue queue)

Specified by:

add in interface QueueManager

get

public EventQueue get(String taskId)

Specified by:

get in interface QueueManager

tap

public EventQueue tap(String taskId)

Specified by:

tap in interface QueueManager

close

public void close(String taskId)

Specified by:

close in interface QueueManager

createOrTap

public EventQueue createOrTap(String taskId)

Specified by:

createOrTap in interface QueueManager

awaitQueuePollerStart

public void awaitQueuePollerStart(EventQueue eventQueue)
                           throws InterruptedException

Specified by:

awaitQueuePollerStart in interface QueueManager

Throws:

InterruptedException