This change fixes a situation where error handling was skipped during
processCommit()
in case the doCommit()
failed. The error handling
was set up via an onErrorResume
operator that was nested inside a
then(...)
, applied to an inner Mono.empty()
. As a consequence,
it would never receive an error signal (effectively decoupling the
onErrorResume from the main chain).
This change simply moves the error handling back one level up. It also
simplifies the doCommit
code a bit by getting rid of the steps that
artificially introduce a Mono<Object>
return type, which is not really
needed.
Comment From: sdeleuze
Thanks @mp911de and @simonbasle for fixing this!