Package org.a2aproject.sdk.server.events

Class QueueClosedEvent

java.lang.Object

org.a2aproject.sdk.server.events.QueueClosedEvent

All Implemented Interfaces:

Event

public class QueueClosedEvent
extends Object
implements Event

Poison pill event used to signal that a queue has been closed.

When a MainQueue is closed on one node, this event is published to Kafka to notify all other nodes consuming replicated events that they should gracefully terminate their event streams for this task.

This event implements the "poison pill" pattern - when EventConsumer encounters this event, it throws EventQueueClosedException to terminate the consumption loop and close the stream.

Note: This is an internal event that is never sent to end clients. The EventConsumer intercepts this event and terminates the stream before it reaches the client.

Constructor Summary

Constructors

Constructor	Description
QueueClosedEvent(String taskId)

Method Summary

Modifier and Type	Method	Description
String	getTaskId()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

QueueClosedEvent

public QueueClosedEvent(String taskId)

Method Details

getTaskId

public String getTaskId()

toString

public String toString()

Overrides:

toString in class Object