Struct ServiceWait 

pub struct ServiceWait<'a> {
    pub registry: &'a ConnectedWorkerRegistry,
    pub declarations: &'a QueueDeclarationSource,
    pub config: &'a QueueServiceConfig,
    pub state: &'a QueueServiceState,
    pub address: &'a ServiceAddress,
    pub workflow_id: &'a WorkflowId,
    pub activity_id: &'a ActivityId,
    pub publisher: Option<&'a ClusterEventPublisher>,
}

Everything the wait needs that outlives one iteration.

Fields

registry: &'a ConnectedWorkerRegistry

Live connected-worker registry.

declarations: &'a QueueDeclarationSource

Deployed queue declarations.

config: &'a QueueServiceConfig

Operator’s policies and clocks.

state: &'a QueueServiceState

Queryable unserved-queue state.

address: &'a ServiceAddress

Address this dispatch needs served.

workflow_id: &'a WorkflowId

Owning workflow.

activity_id: &'a ActivityId

Activity ordinal recorded in history.

publisher: Option<&'a ClusterEventPublisher>

Cluster-event publisher an UNBOUNDED park announces itself on (#266 T4). None (isolated tests) emits nothing on the wire; like the defaulted queue seams on the dispatchers, an unwired publisher loses only the pushed echo — the WARN and the queryable unserved state can never be switched off by wiring. Both production dispatchers share the boot’s one publisher here.