Do we really have to chain 2 onFailures() to be able to log and then handle the failure?

[javadevmtl]

final String traceId = ...;

return pushService.push(...)
                        .chain(v -> Uni.createFrom().completionStage(event.ack()))
                        .invoke(() -> logger.info("Sent to webhook: " + traceId))
                        // This looks funky!
                         .onFailure()
                        .invoke(t-> logger.info("Webhook push failed: " + traceId + ", Exception: " + t.getMessage()))
                        .onFailure().recoverWithUni(t -> {
                            if(t instanceof HttpRetryException)
                                return Uni.createFrom().completionStage(event.nack(t)); // Put to Dlq
                            else if(t instanceof HttpSkipException)
                                return Uni.createFrom().completionStage(event.ack()); // Skip it.
                            else
                                return Uni.createFrom().completionStage(event.nack(t)); // Put to Dlq.

                        });

[manofthepeace]

Have you tested something like this?

final String traceId = ...;

return pushService.push(...)
                        .chain(v -> Uni.createFrom().completionStage(event.ack()))
                        .invoke(() -> logger.info("Sent to webhook: " + traceId))
                        .onFailure().recoverWithUni(t -> {
                            logger.info("Webhook push failed: " + traceId + ", Exception: " + t.getMessage());
                            if(t instanceof HttpRetryException)
                                return Uni.createFrom().completionStage(event.nack(t)); // Put to Dlq
                            else if(t instanceof HttpSkipException)
                                return Uni.createFrom().completionStage(event.ack()); // Skip it.
                            else
                                return Uni.createFrom().completionStage(event.nack(t)); // Put to Dlq.

                        });

[javadevmtl]

Yeah I did and actually went that way anyways. I thought I would try with invoke() since it's what the docs recommend to use for "logging", but I thought it looked awkward :)