PublishRouted so los.pipeline.* events land in LOS_PIPELINE, not rejected

Fixkamo-shared-library
Shipped
6 Julai 2026, 08:27 UTC
Author
Kamo
Commit
d65c7d6

NatsMessageService.publish() pins expectedStream=CHAT_MESSAGES; a los.pipeline.* subject is owned only by the LOS_PIPELINE stream, so the server rejected every transition/condition publish with an expected-stream mismatch — silently (async future swallowed). Switch to publishRouted (route by subject) so the events actually reach LOS_PIPELINE + its webhook worker.

All changes

Je, unaona nini kuhusu usafiri?

Kila moja ya hizi updates ardhi katika nafasi yako ya kazi moja kwa moja. Kuanza bure na kuangalia kukua wiki baada ya wiki.

Kuwa Huru MileleMtazamo wa bei