Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -739,10 +739,10 @@ How a committed row reaches the bus depends on whether a bus is attached to the
service:

- **Bus attached (`service.with_bus(bus)`)** — `repo.outbox(msg).commit(agg)`
commits the row, then **immediately** after commit claims it under a short
lease and publishes it. A crash before the publish, or a publish failure,
leaves the row claimed under that lease; when the lease expires the polling
worker takes it.
claims the row in the commit transaction (born `InFlight` under a short lease)
and publishes it **immediately** after commit. A crash before the publish, or a
publish failure, leaves the row claimed under that lease; when the lease expires
the polling worker takes it.
- **No bus** — the row is committed `pending` and a worker publishes it.

The polling worker is the durable backstop in both cases. It is the same
Expand Down
6 changes: 3 additions & 3 deletions src/microsvc/runtime.rs
Original file line number Diff line number Diff line change
Expand Up @@ -34,9 +34,9 @@ where
///
/// Two effects, both composing with the rest of the builder:
/// - installs an outbox publisher on the repository, so
/// `repo.outbox(msg).commit(agg)` publishes immediately after commit
/// through this bus — the row is claimed under a short lease for that
/// publish, and the polling worker stays the crash/retry backstop;
/// `repo.outbox(msg).commit(agg)` claims the row in the commit transaction
/// and publishes it immediately after commit through this bus (the polling
/// worker stays the crash/retry backstop);
/// - captures how to consume, so [`run`](Self::run) listens for the
/// registered command names (competing) and subscribes to the event names
/// (fan-out).
Expand Down
Loading