LavinMQ::DefinitionsStore

An x-mqtt-topic exchange only routes MQTT publishes, which can't carry an x-delay, so it would ignore x-delayed-exchange and only look delayed. Any value but false is refused, not only true, since the intent is clear.

ameba:disable Metrics/CyclomaticComplexity

Flush buffered definition writes to disk. Used after a bulk operation (e.g. import) that stored its definitions with fsync: false; the whole batch is acknowledged after this, so it waits for follower acks like the per-frame path does.

ameba:disable Metrics/CyclomaticComplexity

The vhost's MQTT exchange. Created with the store rather than declared, so that it's always there when frames are applied — bindings with it as source would be dropped otherwise. It isn't durable, which is what keeps it out of the definitions file.

Insert a pre-built exchange (e.g. MQTT or other internal types that the frame-driven apply path can't construct). Locked; idempotent so callers like init_delayed_queue can re-register on exchange re-creation. Skips persistence and event ticks since these aren't replayed from frames.

Insert a pre-built queue (e.g. DelayedExchangeQueue) that the frame-driven apply path can't construct. Locked; idempotent so it can be called when an exchange is re-imported and a delayed queue with the same name already exists. Skips persistence and event ticks since these aren't replayed from frames.