You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The NACK handler for incoming messages is not executed when an exception occurs during processing while using a signature method that receives a single payload and produces a stream of payloads
#2732
If your method uses the POST_PROCESSING acknowledgment strategy, and the method fails (either by throwing an exception or by producing a failure), the message is automatically nacked with the caught exception
And later:
For method receiving a single payload and producing a stream of payloads, it defaults to pre-processing acknowledgement. However, in this case, post-processing is supported. It waits for all the produced messages to be acknowledged before acknowledging the received one. If one of the produced message is nacked, the received one is nacked immediately.
So post-processing is supported for method receiving a single payload and producing a stream of payloads. But I observed that exception thrown during processing of a message is not causing the nack of the message but rather the application stops processign the channel.
This behavior makes the signature not useful as it’s not possible to use nack.
@Incoming("in")
@Outgoing("out")
Multi<Payload> process(Payload data) {
// exception thrown here is not causing the nack of incomming message
}
The text was updated successfully, but these errors were encountered:
According to the documentation: https://smallrye.io/smallrye-reactive-messaging/4.24.0/concepts/acknowledgement/#negative-acknowledgement
And later:
So post-processing is supported for method receiving a single payload and producing a stream of payloads. But I observed that exception thrown during processing of a message is not causing the nack of the message but rather the application stops processign the channel.
This behavior makes the signature not useful as it’s not possible to use nack.
The text was updated successfully, but these errors were encountered: