Repository navigation

Subscription partitions with a routing inbox - #936

Merged

DavidBadura merged 57 commits into

4.0.xfrom

subscription-partition-inbox

Oct 16, 2026

Merged

Subscription partitions with a routing inbox#936
DavidBadura merged 57 commits into
4.0.xfrom
subscription-partition-inbox

Commits on Oct 14, 2026
- Add subscription partitions with a routing inbox
  DavidBadura
  committed
  0bd3078
- Read only the inbox of a partition and claim by pending work
  DavidBadura
  committed
  d4a8e95
- Claim subscriptions in groups and batch the inbox queries
  DavidBadura
  committed
  b493604
- Insert and update subscriptions in batches
  DavidBadura
  committed
  3c33500
Commits on Oct 15, 2026
- Never let the batches of a claimed group overlap
  DavidBadura
  committed
  24acd43
- Only group subscriptions with close positions
  DavidBadura
  committed
  7520d0a
- Clear the processed messages of a failed partition from its inbox
  DavidBadura
  committed
  20b1bf9
- Require PHP 8.4
  DavidBadura
  committed
  ccbc05f
- Load error context and cleanup tasks lazily for engine lookups
  DavidBadura
  committed
  055d49b
- Keep the subscription store interface small
  DavidBadura
  committed
  21b43b5
- Keep MessageLoader and the claim API small
  DavidBadura
  committed
  29a5ced
- Stop a partitioned subscriber on a systemic failure
  DavidBadura
  committed
  f74cf53
- Add #[PartitionKey] to resolve the key of the processing partition
  DavidBadura
  committed
  ee14631
- Load the inbox messages of a group in chunks
  DavidBadura
  committed
  829dbe5
- Move a partition past inbox messages that no longer exist
  DavidBadura
  committed
  6909233
- Keep the boot of partitioned subscribers linear
  DavidBadura
  committed
  255def0
- Look up the partitions of a run together
  DavidBadura
  committed
  e929d78
- Process the routed messages in the same run
  DavidBadura
  committed
  8963e57
- Only set back partitions when the circuit breaker stopped the subscriber
  DavidBadura
  committed
  3ce0006
- Update the circuit breaker note about #[OnFailed]
  DavidBadura
  committed
  22c72ea
- Compare subscription ids binary on MySQL and MariaDB
  DavidBadura
  committed
  e03bf6c
- Stop a subscription for the rest of the run instead of skipping a message
  DavidBadura
  committed
  4af31f4
- Detach every partition of a detached subscriber
  DavidBadura
  committed
  c2370ae
- Only remove partitions when the main subscription is removed
  DavidBadura
  committed
  4ba4952
- Document that booting partitions do not emit events
  DavidBadura
  committed
  6ab608d
- Explain the message limit of partition groups
  DavidBadura
  committed
  252801d
- Read only the limit of every inbox
  DavidBadura
  committed
  fcee4e6
- Document how batching works with partitions
  DavidBadura
  committed
  009ab9f
- Emit the events of all partitions into the stream of their subscriber
  DavidBadura
  committed
  88f23eb
- Pause and reactivate partitions in groups
  DavidBadura
  committed
  c2c621b
- Remove subscriptions with one statement per chunk
  DavidBadura
  committed
  c5c403f
- Correct the commit granularity of partition groups in the upgrade guide
  DavidBadura
  committed
  cca3d93
- Remove idle partitions
  DavidBadura
  committed
  9eaab6e
- Finish the partitions of a run once subscriber
  DavidBadura
  committed
  4c096be
- Test partitions with two real worker processes
  DavidBadura
  committed
  9d0dfa7
- Test batching and the event emitter with two workers
  DavidBadura
  committed
  f27ed67
- Set the partitioner on the subscriber class
  DavidBadura
  committed
  78ddded
- Add bucket, tag and hashed partitioners
  DavidBadura
  committed
  225f875
- Delete processed inbox rows by their key
  DavidBadura
  committed
  cbb7c0e
- Format the partition key example in the docs
  DavidBadura
  committed
  22e37a9
- Keep the partitioner in the subscriber metadata
  DavidBadura
  committed
  5fb8362
- Load only the partitions that need attention in the status command
  DavidBadura
  committed
  49f53a2
- Count subscriptions per status with stats()
  DavidBadura
  committed
  fe390aa
- Rely on the positive-int type for the number of buckets
  DavidBadura
  committed
  b7cce29
- Wait for locked subscriptions in commands
  DavidBadura
  committed
  1c84d0a
- Never start a partition in the error status of its main subscription
  DavidBadura
  committed
  aa7f57b
- Keep failures of one subscription out of its group
  DavidBadura
  committed
  a355edf
- Store nothing about a held back failure before the run ends
  DavidBadura
  committed
  3ba93a1
- Drop held back failures whenever the circuit breaker trips
  DavidBadura
  committed
  b0df88b
- Decide a stop before OnHandleMessage
  DavidBadura
  committed
  ba086e3
- Find main subscriptions without reading their partitions
  DavidBadura
  committed
  d68c955
- Boot partitions completely without a limit
  DavidBadura
  committed
  fa2aaeb
- Count the partitions left to finish instead of loading them
  DavidBadura
  committed
  fdda557
- Match the tag prefix of TagPartitioner like EventTag does
  DavidBadura
  committed
  e57cd5d
- Reject subscriber ids that collide with partition ids
  DavidBadura
  committed
  98afc20
- Reserve # for partition ids in every subscriber id
  DavidBadura
  committed
  212f7cd
- Count the messages waiting in the inboxes of the partitions
  DavidBadura
  committed
  ad471ca

Commits

Commits on Oct 14, 2026

Commits on Oct 15, 2026