fix: wait for pending ACK callbacks in SolaceIO write finishBundle to prevent batch pipeline data loss [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] - #39664

Open

waterWang wants to merge 7 commits into

apache:masterfrom

waterWang:fix/solace-writer-batch-pipeline-acks

Commits on Aug 6, 2026

fix: add pending publish count tracking to PublishResultHandler for batch pipeline ACK coordination
waterWang
committed
1172c4e
fix: add getPendingPublishCount() to SessionService
waterWang
committed
a5e5d0a
fix: add pendingPublishCount counter and pass to PublishResultHandler
waterWang
committed
b61d306
fix: add incrementPendingPublishes and waitForPendingPublishes helpers
waterWang
committed
f838ad9
fix: wait for pending ACK callbacks in batched writer finishBundle to prevent batch pipeline data loss
waterWang
committed
52f1688
fix: wait for pending ACK callbacks in streaming writer finishBundle to prevent batch pipeline data loss
waterWang
committed
e3e36e7
fix: remove duplicate import in UnboundedSolaceWriter
waterWang
committed
20b1282