Uses of Record Class
com.tnsai.spi.MessageBroker.Message

Packages that use MessageBroker.Message

Package	Description
com.tnsai.spi	Service Provider Interface (SPI) package for TnsAI.

Uses of MessageBroker.Message in com.tnsai.spi

Methods in com.tnsai.spi that return MessageBroker.Message

Modifier and Type	Method	Description
static MessageBroker.Message	MessageBroker.Message.from(String sender, Object payload)	Creates a message with sender and payload.
static MessageBroker.Message	MessageBroker.Message.of(Object payload)	Creates a simple message with payload only.
MessageBroker.Message	MessageBroker.Message.reply(String sender, Object payload)	Creates a reply to this message.
static MessageBroker.Message	MessageBroker.Message.to(String sender, String recipient, Object payload)	Creates a directed message.

Methods in com.tnsai.spi that return types with arguments of type MessageBroker.Message

Modifier and Type	Method	Description
CompletableFuture<MessageBroker.Message>	MessageBroker.request(String targetAgentId, MessageBroker.Message request)	Sends a request and waits for a reply.

Methods in com.tnsai.spi with parameters of type MessageBroker.Message

Modifier and Type	Method	Description
void	MessageBroker.broadcast(MessageBroker.Message message)	Broadcasts a message to all connected agents.
void	MessageBroker.publish(String topic, MessageBroker.Message message)	Publishes a message to a topic.
CompletableFuture<MessageBroker.Message>	MessageBroker.request(String targetAgentId, MessageBroker.Message request)	Sends a request and waits for a reply.
void	MessageBroker.send(String targetAgentId, MessageBroker.Message message)	Sends a direct message to a specific agent.

Method parameters in com.tnsai.spi with type arguments of type MessageBroker.Message

Modifier and Type	Method	Description
String	MessageBroker.subscribe(String agentId, Consumer<MessageBroker.Message> handler)	Subscribes to messages for a specific agent.
String	MessageBroker.subscribeTopic(String topic, Consumer<MessageBroker.Message> handler)	Subscribes to a topic.