Reputation: 321
What happen if any exception is occurred during consume the jms request, is cloud stream handle the exception ( will error move to any specific topic or queue, same scenario for during publish a message) ?
@StreamListener(Sink.INPUT)
public void handle(Request req) throw Exception {
// logic
throw new Exception()
}
Upvotes: 0
Views: 266
Reputation: 4146
Have you tried reading the docs? Spring Cloud Stream Reference
You will be surprised what a little bit of reading can do for you
Upvotes: 2