Stream Message treatment Failover

[MickaelThumerel]

If i understand correctly a message process by the Stream system is dispatch to all consumer.
A failover system (IStreamFailureHandler) is managed if the consumer of the message raised an exception.

In my case i have a consumer call a trigger. (project Democrite)
This trigger is configured dynamically an relay the message to grains or sequences.
Those one are unaware of the message source.

This trigger is able to consume N message in a row to fire N times. This allow N processing in parallel without slowing or overloading the system.
N is configure with the trigger configuration.

My point, and issue, is the trigger will never fail to consume the messages from the stream but sometime the processing of it can fail.
Is their a way to notify the stream about specific message processing failure ? to ensure a failover mechanism like Dead letter box, retry, ...