Hi @msharpe ,
I want the error handler to handle everything in one place Ah okay. Sorry I haven’t had time to dig into this. Not sure if I’m missing another option, but I think three options are:
Implement error handling in one method/function and have a separate @ServiceActivator for each function that calls that Behind the scenes Spring Cloud Stream is taking advantage of Spring Integration channels which is what we are listening to via the @ServiceActivator . I think it should be possible to bridge all of those into a single channel using Spring Integration. Take a look at the @BridgeFrom or Gary’s response to this question on stackoverflow: https://stackoverflow.com/questions/41979612/spring-integration-simple-bridge-with-annotation Let them to go the Error queue and handle them from there (you’d just have to make sure they go to the same error queue)
Hope that helps!