B3 · The Bus
The bus that carries names.
EchoMQ is the Valkey-native bus where the BCS law meets the network: between systems, only branded identities and messages about them cross. A job is a branded entity; the keyspace is born braced, branded, and declared.
Three dives. The keyspace is the contract on the wire; jobs and lanes are the entities it moves; the Stream Tier is the 3.0 destination beside the queue.
The three dives
each a leaf, the teachingThe keyspace
Born braced for the slot, branded at the builder, declared in KEYS[] — the v1 sins of open keys and verbatim interpolation, refused by construction.
Jobs and lanes
A job as a branded entity with a leased lifecycle; lanes as fair sub-queues drained by Lanes.claim; flows as dependencies — relations, not fields.
The Stream Tier
The Stream Tier beside the queue: EchoMQ.Stream the writer, EchoMQ.StreamConsumer the reader law with a polyglot seam, retention as opt-in policy.
A chapter is three dives. Each dive is one idea with one figure you can take apart.
The bus, in one law
echo_mq · emq.roadmap.mdEchoMQ is the bus, and a bus is the place the BCS law meets the network: between systems, only branded identities and messages about them cross. A job is a branded entity — a JOB id with a property bundle — so orders can hand work to codemojex without either reaching into the other’s state. The bus is Valkey-native, lib-only, and re-derived from first principles by the Branded Component System.
The doors
the sibling coursesEchoMQ — the protocol, in depth
The bus B3 narrates, taught rung by rung: the keyspace, the Lua inventory, and the 3.0 Stream Tier — XADD, XREADGROUP, XACK — with conformance on Valkey.
Redis Patterns Applied
The substrate patterns under the bus: sorted sets, atomic Lua moves, locks, and streams — the judgement layer.
/echo-persistenceEcho Persistence — the durable floor
Beneath the volatile tiers: the Graft page engine built twice, the commit-LSN loop, and the stream archive on Tigris. Where Part I says state lives somewhere, this says where it lives durably.
References
sources · relatedSources
- Valkey — Scripting with Luakeys must be passed as arguments, never programmatically generated
- Oban — Robust job processing in Elixirthe Postgres-backed prior art for jobs, queues, and workflows
- Valkey — Introduction to Streamsthe append-only log and consumer groups the tier is built on
Related
- BCS — the course homethe law, the id anatomy, the chapter map
- Echo Persistencethe durable floor beneath the bus