Package com.tnsai.communication.transport

Class LocalTransport

java.lang.Object

com.tnsai.communication.transport.LocalTransport

All Implemented Interfaces:

CommunicationTransport

public class LocalTransport
extends Object
implements CommunicationTransport

Default in-memory transport implementation. Used for single-process applications.

Constructor Summary

Constructors

Constructor	Description
LocalTransport()

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.
void	unregister(String agentId)	Unregisters an agent from the transport layer.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.tnsai.communication.transport.CommunicationTransport

shutdown

Constructor Details

LocalTransport

public LocalTransport()

Method Details

register

public void register(String agentId,
 Consumer<AgentMessage> messageHandler)

Description copied from interface: CommunicationTransport

Registers an agent with the transport layer to receive messages.

Specified by:

register in interface CommunicationTransport

Parameters:

agentId - The ID of the agent to register

messageHandler - The callback to invoke when a message is received for this agent

unregister

public void unregister(String agentId)

Description copied from interface: CommunicationTransport

Unregisters an agent from the transport layer.

Specified by:

unregister in interface CommunicationTransport

Parameters:

agentId - The ID of the agent to unregister

send

public void send(AgentMessage message)

Description copied from interface: CommunicationTransport

Sends a message to a specific receiver.

Specified by:

send in interface CommunicationTransport

Parameters:

message - The message to send

broadcast

public void broadcast(AgentMessage message)

Description copied from interface: CommunicationTransport

Broadcasts a message to all subscribed agents (optional support).

Specified by:

broadcast in interface CommunicationTransport

Parameters:

message - The message to broadcast