Subscribes to policy-specific events on the swarm bus service for a specific client and executes a callback for each event.
This function sets up a listener for events on the "policy-bus" topic associated with a given client ID, invoking the provided callback with
the event data whenever a policy event is received. It is wrapped in beginContext for a clean execution environment and logs the operation
via loggerService. The callback is queued using functools-kit to ensure sequential processing of events. The function supports a wildcard
client ID ("*") for listening to all clients or validates a specific client session. It returns an unsubscribe function to stop listening.
Throws
If the clientId is not "*" and no active session exists for it.
Example
constunsubscribe = listenPolicyEvent("client-123", (event) =>console.log(event)); // Logs each policy event for "client-123" unsubscribe(); // Stops listening
Subscribes to policy-specific events on the swarm bus service for a specific client and executes a callback for each event.
This function sets up a listener for events on the "policy-bus" topic associated with a given client ID, invoking the provided callback with the event data whenever a policy event is received. It is wrapped in
beginContextfor a clean execution environment and logs the operation vialoggerService. The callback is queued usingfunctools-kitto ensure sequential processing of events. The function supports a wildcard client ID ("*") for listening to all clients or validates a specific client session. It returns an unsubscribe function to stop listening.Throws
If the
clientIdis not "*" and no active session exists for it.Example