Package com.tnsai.protocols.transport

Class InternalTransport

java.lang.Object

com.tnsai.protocols.transport.InternalTransport

All Implemented Interfaces:

Transport

public final class InternalTransport
extends Object
implements Transport

In-memory transport for agents in the same JVM. Fastest transport mode with no serialization overhead.

Thread-safe.

Nested Class Summary

Nested classes/interfaces inherited from interface com.tnsai.protocols.transport.Transport

Transport.TransportCallback, Transport.TransportException

Constructor Summary

Constructors

Constructor	Description
InternalTransport()

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.

Methods inherited from class java.lang.Object

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

Constructor Details

InternalTransport

public InternalTransport()

Method Details

send

public com.tnsai.protocols.models.Message send(com.tnsai.protocols.models.Message message)
                                        throws Transport.TransportException

Description copied from interface: Transport

Sends a message to target agent.

Specified by:

send in interface Transport

Parameters:

message - The message to send

Returns:

Response message (null for async transports)

Throws:

Transport.TransportException - if send fails

sendAsync

public void sendAsync(com.tnsai.protocols.models.Message message,
 Transport.TransportCallback callback)

Description copied from interface: Transport

Sends a message asynchronously.

Specified by:

sendAsync in interface Transport

Parameters:

message - The message to send

callback - Callback to invoke when response is received

getMode

public com.tnsai.protocols.transport.TransportMode getMode()

Description copied from interface: Transport

Gets the transport mode.

Specified by:

getMode in interface Transport

Returns:

Transport mode

isSynchronous

public boolean isSynchronous()

Description copied from interface: Transport

Checks if this transport supports synchronous sends.

Specified by:

isSynchronous in interface Transport

Returns:

true if synchronous

start

public void start()

Description copied from interface: Transport

Starts the transport (e.g., HTTP server).

Specified by:

start in interface Transport

stop

public void stop()

Description copied from interface: Transport

Stops the transport.

Specified by:

stop in interface Transport

isRunning

public boolean isRunning()

Description copied from interface: Transport

Checks if transport is running.

Specified by:

isRunning in interface Transport

Returns:

true if running