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

Shipped

July 6, 2026 at 8:27 AM 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.