feat: foreign-broker relay from OutboxSubscriber#44

Merged

lesnik512 merged 14 commits into

mainfrom

feat/foreign-broker-relay

Jun 4, 2026

Commits on Jun 4, 2026

chore: add faststream[kafka] to dev deps for relay tests

lesnik512
and
claude
committed
test: baseline relay from OutboxSubscriber to TestKafkaBroker

lesnik512
and
claude
committed
style: ruff lint fixes for test_relay.py

lesnik512
and
claude
committed
test: relay via KafkaRouter and OutboxRouter publishers/subscribers

lesnik512
and
claude
committed
feat: propagate_inbound_headers kwarg for foreign-broker relay

lesnik512
and
claude
committed
fixup: strengthen propagate_inbound_headers tests, fix ty dialect

lesnik512
and
claude
committed
feat: refuse OutboxResponse + foreign-publisher dual-fire

lesnik512
and
claude
committed
feat: WARN on unstarted foreign-publisher brokers at start()

lesnik512
and
claude
committed
test: at-least-once relay under simulated foreign-publish failure

lesnik512
and
claude
committed
docs: add foreign-broker relay tutorial, promote to top of Usage nav

lesnik512
and
claude
committed
docs: intro callout and CLAUDE.md subsection for foreign-broker relay

lesnik512
and
claude
committed
docs: rewrite README quickstart around the outbox relay

lesnik512
and
claude
committed
test: pragma upstream-mirrored exception paths in process_message override

lesnik512
and
claude
committed
test: assert explicit Response headers win over propagate_inbound_headers

lesnik512
and
claude
committed