Member Junction
    Preparing search index...

    Runs this instance's share of work-queue subscriptions (03 §11). Every claim is atomic against shared state, so any number of hosts may run the same subscription; each host only decides what IT runs. Start, Reconcile and Shutdown are serialized; Shutdown() is one shared promise that resolves only when the drain has finished. Consumers are opened by the host and closed by the host — ConsumerRuntime.Stop() does not close its consumer.

    Implements

    Index

    Constructors

    Accessors

    Methods