feat(mq): give every tenant a queue of its own - #612

Merged

taitelee merged 15 commits into

mainfrom

mq-tenant-streams

Sep 25, 2026

Commits on Sep 25, 2026

fix(mq): a failed resize restores the ingest stream's own cap; review fixes
taitelee
committed
db2d20a
fix(app): a rejected tenant keeps its replay history; review fixes
taitelee
committed
07c6a91
fix(mq): share the hub bridge's fetch-ahead across tenants; review fixes
taitelee
committed
04aad9f
fix(mq): publish only into a queue the broker recorded open; review fixes
taitelee
committed
57870c4
docs(mq): a consumer that cannot join a queue opened at runtime; review fixes
taitelee
committed
7cdb794
fix(mq): pace publish-side retries of a queue that cannot open; review fixes
taitelee
committed
e199a03
test(mq): one tenant's failed purge stops no other; review fixes
taitelee
committed
55137d8
docs(mq): size a dead-letter stream the shrink guard kept; review fixes
taitelee
committed
060ca9e
fix(mq): pace a park's reopen, and warn only on a missing consumer; review fixes
taitelee
committed
9344f1b
test(mq): keep the streams directory occupied through a failed open
taitelee
committed
f5d8f48
test(mq): keep the streams directory occupied through the first failed open too
taitelee
committed
eb9f740