ProtectedconstructorProtectedExecutorThe shared server provider. Used ONLY to mint independent executors and as PublishAs's default (03 §11).
The metadata tier. Config() delegates to it.
StaticInstanceOptionalsupport: FilterSupportLoads (or refreshes) the metadata tier and remembers the provider the server side runs against.
OptionalforceRefresh: booleanOptionalcontextUser: UserInfoOptionalprovider: IMetadataProviderProtectedEnrichThe single manifest post-processing step: the enricher registered for the manifest's DriverClass renders the
transport's artifacts (AWS: DriverArtifacts.SnsFilterPolicy, CD8). Database manifests pass through; a cloud
manifest whose engine entry was not imported is refused (03 §0, F12).
Autoscaler metric (03 §11): claimable Pending (partition rules applied) + InFlight, each capped at 1000.
Cloud subscriptions answer Supported: false — scale those from the broker's own metrics.
ONE cached instance per transport, however it is reached. A changed transport builds a new driver and closes the old one.
The Global Object Store is a place to store global objects that need to be shared across the application. Depending on the execution environment, this could be the window object in a browser, or the global object in a node environment, or something else in other contexts. The key here is that in some cases static variables are not truly shared because it is possible that a given class might have copies of its code in multiple paths in a deployed application. This approach ensures that no matter how many code copies might exist, there is only one instance of the object in question by using the Global Object Store.
Saves each binding as the caller's user (validation, permissions, record changes apply), then re-reads metadata as the system user.
Public (F13): drivers call it through TransportDriverDeps, and plan 06's sweeper calls it directly.
IN-PROCESS ONLY (03 §11): fires for dead letters produced by this process. Alert durably from subscription stats.
Host Kick hook (plan 06); returns unsubscribe.
Publishes as the engine's system user.
Closes every cached driver and the publish coordinator, releasing their independent executors (F8).
Topology rows + capability gating + driver ValidateBindings + database prerequisites (RCSI, 03 §6).
Protected StaticgetReturns the singleton instance of the class. If the instance does not exist, it is created and stored in the Global Object Store. If className is provided it will be used as part of the key in the Global Object Store, otherwise the actual class name will be used. NOTE: the class name used by default is the lowest level of the object hierarchy, so if you have a class that extends another class, the lowest level class name will be used.
OptionalclassName: string
Server tier: the in-process publisher, driver registry and operator entry point (03 §11).
🚨 THIS CLASS IS A FACADE, NOT A SUBCLASS. Metadata lives in
WorkQueueEngineBase(browser-safe, loaded once);BaseEngine<T>is a singleton keyed on its own type, so a server subclass would give a second cache of the same three entities — the same reasonAIEnginecomposesAIEngineBase. The proxy list below is CLOSED — it is the list 03 §11 publishes. Reach anything else asengine.Metadata.Member(…).Not an IStartupSink and not registered for startup: MJServer configures it explicitly when the
workQueuesection is enabled (plan 06).