Package com.tnsai.communication.transport

Interface CommunicationTransport

All Known Implementing Classes:
LocalTransport
public interface CommunicationTransport
Abstraction for the underlying message transport mechanism. Enables switching between in-memory (local) and distributed (Redis, RabbitMQ) communication.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    broadcast(AgentMessage message)
    Broadcasts a message to all subscribed agents (optional support).
    void
    register(String agentId, Consumer<AgentMessage> messageHandler)
    Registers an agent with the transport layer to receive messages.
    void
    send(AgentMessage message)
    Sends a message to a specific receiver.
    default void
    shutdown()
    Stops the transport layer and releases resources.
    void
    unregister(String agentId)
    Unregisters an agent from the transport layer.

  • Method Details

    • register

      void register(String agentId, Consumer<AgentMessage> messageHandler)
      Registers an agent with the transport layer to receive messages.
      Parameters:
      agentId - The ID of the agent to register
      messageHandler - The callback to invoke when a message is received for this agent

    • unregister

      void unregister(String agentId)
      Unregisters an agent from the transport layer.
      Parameters:
      agentId - The ID of the agent to unregister

    • send

      void send(AgentMessage message)
      Sends a message to a specific receiver.
      Parameters:
      message - The message to send

    • broadcast

      void broadcast(AgentMessage message)
      Broadcasts a message to all subscribed agents (optional support).
      Parameters:
      message - The message to broadcast

    • shutdown

      default void shutdown()
      Stops the transport layer and releases resources.