Обработчик ошибок не вызывается, пока не будут выполнены все попытки в Spring Cloud Stream

Question

Я пытаюсь написать обработчик ошибок для моего приложения Spring Cloud Stream;однако обработчик ошибок вызывается только после того, как были предприняты все попытки.Есть ли способ перехватить каждое исключение и обработать его индивидуально, вместо того, чтобы ждать, пока повторные попытки будут исчерпаны?

Answer 1

Что вы подразумеваете под «процессом»?

Весь смысл повторения попытки состоит в том, чтобы повторять ошибки до тех пор, пока попытки не будут успешными или попытки исчерпаны.

Тем не менее, вы можете подключить свой собственный RetryTemplate как описано здесь и добавьте к нему RetryListener, чтобы вы могли получать уведомления о каждой ошибке.