One consumer, one reader, however many patterns a module registers #19

Merged

mesh-admin merged 1 commits from fix/one-consumer-one-loop into main

2026-09-28 14:25:47 +00:00

Author	SHA1	Message	Date
jschoubben	38831c5c56	One consumer, one reader, however many patterns a module registers A module has exactly one durable consumer, and each subscribe() started its own reader of it. Two readers split the stream between them, and a reader that receives a message its own pattern does not match acknowledges it — which is the right answer for a filter wider than anything registered, and silent loss when the message was another handler's. The first module to subscribe twice would have dropped roughly half of each kind of event with nothing reporting it. Every registration is now dispatched from one reader, and a message is acknowledged once every handler it is for has taken it.	2026-09-28 16:25:42 +02:00

Author

SHA1

Message

Date

jschoubben

38831c5c56

One consumer, one reader, however many patterns a module registers

A module has exactly one durable consumer, and each subscribe() started its own reader of it. Two
readers split the stream between them, and a reader that receives a message its own pattern does not
match acknowledges it — which is the right answer for a filter wider than anything registered, and
silent loss when the message was another handler's. The first module to subscribe twice would have
dropped roughly half of each kind of event with nothing reporting it.

Every registration is now dispatched from one reader, and a message is acknowledged once every handler
it is for has taken it.

2026-09-28 16:25:42 +02:00