Package org.a2aproject.sdk.client.transport.jsonrpc

Class JSONRPCTransport

java.lang.Object
org.a2aproject.sdk.client.transport.jsonrpc.JSONRPCTransport
All Implemented Interfaces:
org.a2aproject.sdk.client.transport.spi.ClientTransport
public class JSONRPCTransport extends Object implements org.a2aproject.sdk.client.transport.spi.ClientTransport

  • Constructor Summary

    Constructors
    Constructor
    Description
    JSONRPCTransport(@Nullable org.a2aproject.sdk.client.http.A2AHttpClient httpClient, @Nullable org.a2aproject.sdk.spec.AgentCard agentCard, org.a2aproject.sdk.spec.AgentInterface agentInterface, @Nullable List<org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallInterceptor> interceptors)
     
    JSONRPCTransport(String agentUrl)
     
    JSONRPCTransport(org.a2aproject.sdk.spec.AgentCard agentCard)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.a2aproject.sdk.spec.Task
    cancelTask(org.a2aproject.sdk.spec.CancelTaskParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context)
     
    void
    close()
     
    org.a2aproject.sdk.spec.TaskPushNotificationConfig
    createTaskPushNotificationConfiguration(org.a2aproject.sdk.spec.TaskPushNotificationConfig request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context)
     
    void
    deleteTaskPushNotificationConfigurations(org.a2aproject.sdk.spec.DeleteTaskPushNotificationConfigParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context)
     
    org.a2aproject.sdk.spec.AgentCard
    getExtendedAgentCard(org.a2aproject.sdk.spec.GetExtendedAgentCardParams params, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context)
     
    org.a2aproject.sdk.spec.Task
    getTask(org.a2aproject.sdk.spec.TaskQueryParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context)
     
    org.a2aproject.sdk.spec.TaskPushNotificationConfig
    getTaskPushNotificationConfiguration(org.a2aproject.sdk.spec.GetTaskPushNotificationConfigParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context)
     
    org.a2aproject.sdk.spec.ListTaskPushNotificationConfigsResult
    listTaskPushNotificationConfigurations(org.a2aproject.sdk.spec.ListTaskPushNotificationConfigsParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context)
     
    org.a2aproject.sdk.jsonrpc.common.wrappers.ListTasksResult
    listTasks(org.a2aproject.sdk.spec.ListTasksParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context)
     
    org.a2aproject.sdk.spec.EventKind
    sendMessage(org.a2aproject.sdk.spec.MessageSendParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context)
     
    void
    sendMessageStreaming(org.a2aproject.sdk.spec.MessageSendParams request, Consumer<org.a2aproject.sdk.spec.StreamingEventKind> eventConsumer, @Nullable Consumer<Throwable> errorConsumer, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context)
     
    void
    subscribeToTask(org.a2aproject.sdk.spec.TaskIdParams request, Consumer<org.a2aproject.sdk.spec.StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • JSONRPCTransport

      public JSONRPCTransport(String agentUrl)

    • JSONRPCTransport

      public JSONRPCTransport(org.a2aproject.sdk.spec.AgentCard agentCard)

    • JSONRPCTransport

      public JSONRPCTransport(@Nullable org.a2aproject.sdk.client.http.A2AHttpClient httpClient, @Nullable org.a2aproject.sdk.spec.AgentCard agentCard, org.a2aproject.sdk.spec.AgentInterface agentInterface, @Nullable List<org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallInterceptor> interceptors)

  • Method Details

    • sendMessage

      public org.a2aproject.sdk.spec.EventKind sendMessage(org.a2aproject.sdk.spec.MessageSendParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context) throws org.a2aproject.sdk.spec.A2AClientException
      Specified by:
      sendMessage in interface org.a2aproject.sdk.client.transport.spi.ClientTransport
      Throws:
      org.a2aproject.sdk.spec.A2AClientException

    • sendMessageStreaming

      public void sendMessageStreaming(org.a2aproject.sdk.spec.MessageSendParams request, Consumer<org.a2aproject.sdk.spec.StreamingEventKind> eventConsumer, @Nullable Consumer<Throwable> errorConsumer, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context) throws org.a2aproject.sdk.spec.A2AClientException
      Specified by:
      sendMessageStreaming in interface org.a2aproject.sdk.client.transport.spi.ClientTransport
      Throws:
      org.a2aproject.sdk.spec.A2AClientException

    • getTask

      public org.a2aproject.sdk.spec.Task getTask(org.a2aproject.sdk.spec.TaskQueryParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context) throws org.a2aproject.sdk.spec.A2AClientException
      Specified by:
      getTask in interface org.a2aproject.sdk.client.transport.spi.ClientTransport
      Throws:
      org.a2aproject.sdk.spec.A2AClientException

    • cancelTask

      public org.a2aproject.sdk.spec.Task cancelTask(org.a2aproject.sdk.spec.CancelTaskParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context) throws org.a2aproject.sdk.spec.A2AClientException
      Specified by:
      cancelTask in interface org.a2aproject.sdk.client.transport.spi.ClientTransport
      Throws:
      org.a2aproject.sdk.spec.A2AClientException

    • listTasks

      public org.a2aproject.sdk.jsonrpc.common.wrappers.ListTasksResult listTasks(org.a2aproject.sdk.spec.ListTasksParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context) throws org.a2aproject.sdk.spec.A2AClientException
      Specified by:
      listTasks in interface org.a2aproject.sdk.client.transport.spi.ClientTransport
      Throws:
      org.a2aproject.sdk.spec.A2AClientException

    • createTaskPushNotificationConfiguration

      public org.a2aproject.sdk.spec.TaskPushNotificationConfig createTaskPushNotificationConfiguration(org.a2aproject.sdk.spec.TaskPushNotificationConfig request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context) throws org.a2aproject.sdk.spec.A2AClientException
      Specified by:
      createTaskPushNotificationConfiguration in interface org.a2aproject.sdk.client.transport.spi.ClientTransport
      Throws:
      org.a2aproject.sdk.spec.A2AClientException

    • getTaskPushNotificationConfiguration

      public org.a2aproject.sdk.spec.TaskPushNotificationConfig getTaskPushNotificationConfiguration(org.a2aproject.sdk.spec.GetTaskPushNotificationConfigParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context) throws org.a2aproject.sdk.spec.A2AClientException
      Specified by:
      getTaskPushNotificationConfiguration in interface org.a2aproject.sdk.client.transport.spi.ClientTransport
      Throws:
      org.a2aproject.sdk.spec.A2AClientException

    • listTaskPushNotificationConfigurations

      public org.a2aproject.sdk.spec.ListTaskPushNotificationConfigsResult listTaskPushNotificationConfigurations(org.a2aproject.sdk.spec.ListTaskPushNotificationConfigsParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context) throws org.a2aproject.sdk.spec.A2AClientException
      Specified by:
      listTaskPushNotificationConfigurations in interface org.a2aproject.sdk.client.transport.spi.ClientTransport
      Throws:
      org.a2aproject.sdk.spec.A2AClientException

    • deleteTaskPushNotificationConfigurations

      public void deleteTaskPushNotificationConfigurations(org.a2aproject.sdk.spec.DeleteTaskPushNotificationConfigParams request, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context) throws org.a2aproject.sdk.spec.A2AClientException
      Specified by:
      deleteTaskPushNotificationConfigurations in interface org.a2aproject.sdk.client.transport.spi.ClientTransport
      Throws:
      org.a2aproject.sdk.spec.A2AClientException

    • subscribeToTask

      public void subscribeToTask(org.a2aproject.sdk.spec.TaskIdParams request, Consumer<org.a2aproject.sdk.spec.StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context) throws org.a2aproject.sdk.spec.A2AClientException
      Specified by:
      subscribeToTask in interface org.a2aproject.sdk.client.transport.spi.ClientTransport
      Throws:
      org.a2aproject.sdk.spec.A2AClientException

    • getExtendedAgentCard

      public org.a2aproject.sdk.spec.AgentCard getExtendedAgentCard(org.a2aproject.sdk.spec.GetExtendedAgentCardParams params, @Nullable org.a2aproject.sdk.client.transport.spi.interceptors.ClientCallContext context) throws org.a2aproject.sdk.spec.A2AClientException
      Specified by:
      getExtendedAgentCard in interface org.a2aproject.sdk.client.transport.spi.ClientTransport
      Throws:
      org.a2aproject.sdk.spec.A2AClientException

    • close

      public void close()
      Specified by:
      close in interface org.a2aproject.sdk.client.transport.spi.ClientTransport