Class AuthorizationListener

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.auth.AuthorizationListener
All Implemented Interfaces:
org.mule.runtime.api.lifecycle.Initialisable

@DisplayName("A2A Server - Authorization Listener") @MediaType("application/json") public class AuthorizationListener extends BaseServerListener<String,RequestAttributes>
A2A Server authorization listener that gates JSON-RPC methods which do not have a dedicated listener. If the flow completes successfully the request is authorized; if the flow raises an error the request is denied and a 403 Forbidden response is returned to the caller.
  • Constructor Details

    • AuthorizationListener

      public AuthorizationListener()
  • 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>
    • onSuccess

      @OnSuccess public void onSuccess(org.mule.sdk.api.runtime.source.SourceCallbackContext context)
    • onError

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

      @OnTerminate public void onTerminate()