Package com.mulesoft.connectors.a2a.internal.server.listener.task

Class TaskStreamListener

java.lang.Object

org.mule.sdk.api.runtime.source.Source<T,A>

com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener<String,RequestAttributes>

com.mulesoft.connectors.a2a.internal.server.listener.task.TaskStreamListener

All Implemented Interfaces:

org.mule.runtime.api.lifecycle.Initialisable

@DisplayName("A2A Server - On Task Stream Listener")
@MetadataScope(outputResolver=MessageSendParamsOutputResolver.class)
@MediaType("application/json")
public class TaskStreamListener
extends BaseServerListener<String,RequestAttributes>

Server-side listener for streaming task requests. Activated when clients send streaming requests (messages/stream) to trigger server-side flows and enable real-time SSE event delivery.

Field Summary

Fields inherited from class com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener

componentLocation, config, connectionProvider, REQUEST_CONTEXT_VAR, serverAgent

Fields inherited from interface org.mule.runtime.api.lifecycle.Initialisable

PHASE_NAME

Constructor Summary

Constructors

Constructor	Description
TaskStreamListener()

Method Summary

Modifier and Type	Method	Description
protected void	doInitialise()
void	onError(org.mule.runtime.api.message.Error error, org.mule.sdk.api.runtime.source.SourceCallbackContext context)
void	onStart(org.mule.sdk.api.runtime.source.SourceCallback<String,RequestAttributes> sourceCallback)
void	onStop()

Methods inherited from class com.mulesoft.connectors.a2a.internal.server.listener.BaseServerListener

getDslTag, initialise, recoverRequestContext, storeInContext

Methods inherited from class java.lang.Object

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

Constructor Details

TaskStreamListener

public TaskStreamListener()

Method Details

doInitialise

protected void doInitialise()
                     throws org.mule.runtime.api.lifecycle.InitialisationException

Overrides:

doInitialise in class BaseServerListener<String,RequestAttributes>

Throws:

org.mule.runtime.api.lifecycle.InitialisationException

onStart

public void onStart(org.mule.sdk.api.runtime.source.SourceCallback<String,RequestAttributes> sourceCallback)
             throws org.mule.runtime.api.exception.MuleException

Specified by:

onStart in class org.mule.sdk.api.runtime.source.Source<String,RequestAttributes>

Throws:

org.mule.runtime.api.exception.MuleException

onStop

public void onStop()

Specified by:

onStop in class org.mule.sdk.api.runtime.source.Source<String,RequestAttributes>

onError

@OnError
public void onError(org.mule.runtime.api.message.Error error,
 org.mule.sdk.api.runtime.source.SourceCallbackContext context)