Package io.a2a.server.events

Class EventQueue

java.lang.Object

io.a2a.server.events.EventQueue

All Implemented Interfaces:

AutoCloseable

public abstract class EventQueue
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	EventQueue.EventQueueBuilder

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_QUEUE_SIZE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	EventQueue()
protected	EventQueue(int queueSize)
protected	EventQueue(EventQueue parent)

Method Summary

Modifier and Type	Method	Description
abstract void	awaitQueuePollerStart()
abstract void	close()
abstract void	close(boolean immediate)
Event	dequeueEvent(int waitMilliSeconds)
void	doClose()
void	doClose(boolean immediate)
void	enqueueEvent(Event event)
int	getQueueSize()
boolean	isClosed()
void	taskDone()

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_QUEUE_SIZE

public static final int DEFAULT_QUEUE_SIZE

See Also:

• Constant Field Values

Constructor Details

EventQueue

protected EventQueue()

EventQueue

protected EventQueue(int queueSize)

EventQueue

protected EventQueue(EventQueue parent)

Method Details

getQueueSize

public int getQueueSize()

awaitQueuePollerStart

public abstract void awaitQueuePollerStart()
                                    throws InterruptedException

Throws:

InterruptedException

enqueueEvent

public void enqueueEvent(Event event)

dequeueEvent

public Event dequeueEvent(int waitMilliSeconds)
                   throws EventQueueClosedException

Throws:

EventQueueClosedException

taskDone

public void taskDone()

close

public abstract void close()

Specified by:

close in interface AutoCloseable

close

public abstract void close(boolean immediate)

isClosed

public boolean isClosed()

doClose

public void doClose()

doClose

public void doClose(boolean immediate)