Package com.tnsai.protocols.transport

Interface Transport

All Known Implementing Classes:
HttpTransport, InternalTransport
public interface Transport
Transport interface for sending messages between agents. Implementations handle different transport modes (internal, HTTP, WebSocket).

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static interface 
    Transport.TransportCallback
    Callback interface for async sends.
    static class 
    Transport.TransportException
    Transport exception.

  • Method Summary

    Modifier and Type
    Method
    Description
    com.tnsai.protocols.transport.TransportMode
    getMode()
    Gets the transport mode.
    boolean
    isRunning()
    Checks if transport is running.
    boolean
    isSynchronous()
    Checks if this transport supports synchronous sends.
    com.tnsai.protocols.models.Message
    send(com.tnsai.protocols.models.Message message)
    Sends a message to target agent.
    void
    sendAsync(com.tnsai.protocols.models.Message message, Transport.TransportCallback callback)
    Sends a message asynchronously.
    void
    start()
    Starts the transport (e.g., HTTP server).
    void
    stop()
    Stops the transport.

  • Method Details

    • send

      com.tnsai.protocols.models.Message send(com.tnsai.protocols.models.Message message) throws Transport.TransportException
      Sends a message to target agent.
      Parameters:
      message - The message to send
      Returns:
      Response message (null for async transports)
      Throws:
      Transport.TransportException - if send fails

    • sendAsync

      void sendAsync(com.tnsai.protocols.models.Message message, Transport.TransportCallback callback)
      Sends a message asynchronously.
      Parameters:
      message - The message to send
      callback - Callback to invoke when response is received

    • getMode

      com.tnsai.protocols.transport.TransportMode getMode()
      Gets the transport mode.
      Returns:
      Transport mode

    • isSynchronous

      boolean isSynchronous()
      Checks if this transport supports synchronous sends.
      Returns:
      true if synchronous

    • start

      void start() throws Transport.TransportException
      Starts the transport (e.g., HTTP server).
      Throws:
      Transport.TransportException

    • stop

      void stop()
      Stops the transport.

    • isRunning

      boolean isRunning()
      Checks if transport is running.
      Returns:
      true if running