Package com.mulesoft.connectors.a2a.internal.server.agent.repository

Class StreamingContext

java.lang.Object

com.mulesoft.connectors.a2a.internal.server.agent.repository.StreamingContext

All Implemented Interfaces:

Serializable

public class StreamingContext
extends Object
implements Serializable

Groups all SSE/streaming-related context data for a task.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
StreamingContext()	Default constructor for serialization and cases where context is built incrementally.
StreamingContext(String requestId, String workerInstanceId)	Constructor for creating a complete streaming context.

Method Summary

Modifier and Type	Method	Description
void	addBufferedEvent(TaskEvent event)
List<TaskEvent>	getBufferedEvents()
String	getRequestId()
String	getWorkerInstanceId()
void	setRequestId(String requestId)
void	setWorkerInstanceId(String workerInstanceId)

Methods inherited from class java.lang.Object

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

Constructor Details

StreamingContext

public StreamingContext()

Default constructor for serialization and cases where context is built incrementally.

StreamingContext

public StreamingContext(String requestId,
 String workerInstanceId)

Constructor for creating a complete streaming context.

Parameters:

requestId - the original JSON-RPC request identifier

workerInstanceId - the worker instance identifier

Method Details

getRequestId

public String getRequestId()

setRequestId

public void setRequestId(String requestId)

getWorkerInstanceId

public String getWorkerInstanceId()

setWorkerInstanceId

public void setWorkerInstanceId(String workerInstanceId)

getBufferedEvents

public List<TaskEvent> getBufferedEvents()

addBufferedEvent

public void addBufferedEvent(TaskEvent event)