Skip to main content

init

agentmux_srv::backend::notify::router

Function init 

Source 
pub fn init(
    broker: Arc<Broker>,
    config: Arc<ConfigState>,
    store: Arc<Store>,
    reactive: &'static ReactiveHandler,
) -> Arc<Router> ⓘ
Expand description

Get-or-create the router for this broker. Idempotent.

On creation it also attaches the srv-side sources: an observer on the broker (agentfailure → AgentCrashed) and the reactive handler’s needs-review hook (ESCALATE=required jekt → MessageNeedsReview).