storage:messageRouting

storage:messageRouting

Field	Value
Prefix	storage:messageRouting
Namespace constant	MessageRoutingNamespace
Subjects constant	MessageRoutingSubjects
Kind	storage
Schema record	<inline>
Tier	framework
Package	@makaio/services-core
Defined in	packages/services/core/src/session/message-routing/namespace.ts

Subjects

Key	Wire	Type	Schema
getByMessage	storage:messageRouting.getByMessage	rpc	—
getCompleted	storage:messageRouting.getCompleted	rpc	—
isComplete	storage:messageRouting.isComplete	rpc	—
record	storage:messageRouting.record	rpc	—

Subject Details

storage:messageRouting.getByMessage (rpc)

Get routing status for a message.

Subject: storage:messageRouting.getByMessage Type: Request (RPC)

Request:

Field	Type	Required
messageId	string	yes

Response:

Field	Type	Required
routing	{ messageId: string; agentId: string; status: "completed" | "acknowledged" | "sent"; timestamp: number; error?: string | undefined; }[]	yes

storage:messageRouting.getCompleted (rpc)

Get all completed routings for a message. Used to check if all target agents have responded.

Subject: storage:messageRouting.getCompleted Type: Request (RPC)

Request:

Field	Type	Required
messageId	string	yes

Response:

Field	Type	Required
agentIds	string[]	yes

storage:messageRouting.isComplete (rpc)

Check if all target agents have completed for a message.

Subject: storage:messageRouting.isComplete Type: Request (RPC)

Request:

Field	Type	Required
messageId	string	yes
targetAgentIds	string[]	yes

Response:

Field	Type	Required
complete	boolean	yes
pending	string[]	yes

storage:messageRouting.record (rpc)

Record routing status for a message to an agent.

Subject: storage:messageRouting.record Type: Request (RPC)

Request:

Field	Type	Required
agentId	string	yes
error	string | undefined	no
messageId	string	yes
status	"completed" | "acknowledged" | "sent"	yes
timestamp	number	yes

Response:

Field	Type	Required
success	boolean	yes

---

Auto-generated by yarn docs:bus. Do not edit manually.