Class AgentBus

Index

Constructors

Methods

publish receive send subscribe verify

Constructors

constructor

new AgentBus(): AgentBus

Returns AgentBus

Methods

publish

publish(message: BusMessage): void
Compatibility API for legacy call pattern.
Parameters
- message: BusMessage
Returns void
- Defined in src/watch/agentBus.ts:63

receive

receive(agentId: string): AgentMessage[]
Parameters
- agentId: string
Returns AgentMessage[]
- Defined in src/watch/agentBus.ts:47

send

send(from: string, to: string, payload: unknown): AgentMessage
Parameters
- from: string
- to: string
- payload: unknown
Returns AgentMessage
- Defined in src/watch/agentBus.ts:28

subscribe(handler: Subscriber): void
Parameters
- handler: Subscriber
Returns void
- Defined in src/watch/agentBus.ts:71

verify

verify(message: AgentMessage): boolean
Parameters
- message: AgentMessage
Returns boolean
- Defined in src/watch/agentBus.ts:53