feat: batched outbox forwarding for combined message channels (Enterprise) - #692

Merged

dgafka merged 25 commits into

mainfrom

feat/combined-channel-batched-forwarding

Aug 6, 2026

Commits on Aug 4, 2026

refactor: rename channel builder withAsyncPublishing to withBatchedNonBlockingDelivery
dgafka
committed
6b30acd
feat: batched drain-and-group forwarding for combined channel relays (Enterprise)
dgafka
committed
db81ef8
feat: configurable max forwarding batch size on message channel builders
dgafka
committed
d765c17
test: batch forwarding into target with batched non-blocking delivery delivers all messages in order
dgafka
committed
f4f5597
test: non-enterprise relay keeps one message per consumer run
dgafka
committed
e412e5d
test: shared outbox groups drained messages per routing slip target
dgafka
committed
8e0587d
test: failed forwarding keeps all drained messages available on outbox
dgafka
committed
ec532b8
feat: benchmark outbox relay batched vs message-by-message for AMQP and Kafka
dgafka
committed
80d6269
feat: per-message delivery failure isolation with release for redelivery, connection failures abort cycle for transactional retry
dgafka
committed
a4565d9
fix: relay forwards bypass message collector per message, keeping collector protection for handler-published messages
dgafka
committed
e2dc0b9
refactor: rename missed kafka channel builder toggle call site
dgafka
committed
7f1c6db
refactor: rename channel builder toggle to withHighThroughputPublishing
dgafka
committed
aa2b6cd
fix: use enterprise licence key for Kafka message-by-message outbox relay benchmark
dgafka
committed
c21551e
refactor: confine batched forwarding to combined channel relays with batch size on CombinedMessageChannel, skip draining non-auto-acked sources
dgafka
committed
40d3d09
fix: pin kafka relay baseline benchmark to batch size one under enterprise licence
dgafka
committed
ebddf02
fix: no-wait drain receive and final failure strategy honoured for drained messages
dgafka
committed
5b9b6ff
fix: gate drain sources to marker-capable channel builders and disable collector for relay targets at configuration time
dgafka
committed
ac9cdfd

Navigation Menu

Uh oh!

Uh oh!

feat: batched outbox forwarding for combined message channels (Enterprise) - #692

feat: batched outbox forwarding for combined message channels (Enterprise)#692
dgafka merged 25 commits into
mainfrom
feat/combined-channel-batched-forwarding

Commits on Aug 4, 2026

refactor: rename channel builder withAsyncPublishing to withBatchedNonBlockingDelivery

feat: batched drain-and-group forwarding for combined channel relays (Enterprise)

feat: configurable max forwarding batch size on message channel builders

test: batch forwarding into target with batched non-blocking delivery delivers all messages in order

test: non-enterprise relay keeps one message per consumer run

test: shared outbox groups drained messages per routing slip target

test: failed forwarding keeps all drained messages available on outbox

feat: benchmark outbox relay batched vs message-by-message for AMQP and Kafka

feat: per-message delivery failure isolation with release for redelivery, connection failures abort cycle for transactional retry

fix: relay forwards bypass message collector per message, keeping collector protection for handler-published messages

refactor: rename missed kafka channel builder toggle call site

refactor: rename channel builder toggle to withHighThroughputPublishing

fix: use enterprise licence key for Kafka message-by-message outbox relay benchmark

refactor: confine batched forwarding to combined channel relays with batch size on CombinedMessageChannel, skip draining non-auto-acked sources

fix: pin kafka relay baseline benchmark to batch size one under enterprise licence

fix: no-wait drain receive and final failure strategy honoured for drained messages

fix: gate drain sources to marker-capable channel builders and disable collector for relay targets at configuration time

Commits on Aug 5, 2026

refactor: standalone direct-SQL batch publishing endpoint for combined channel outbox relays

perf: wire-format batch entries and low-overhead batch inserts for pollable channels

fix: bump stale pdo-event-sourcing dev pin in JmsConverter to current release line

test: consumer execution limit maps one handled execution to one forwarding batch

feat: configurable final failure strategy on batch forwarding with per-run delivery assertions

feat: round-robin multi-tenant outbox publishing

Commits on Aug 6, 2026

bench: outbox relay draining into RabbitMQ, Kafka, Redis and SQS targets

feat: OutboxForwardingMessageChannel as the single definition of an outbox relay