Пример обработки исключений в интеграции Spring ⇐ JAVA

[Anonymous]

Я ищу хороший пример обработки ошибок для интеграции Spring. Все, что я действительно хочу сделать, это вызвать метод в случае сбоя этого потока. Идея заключается в том, что вызываемый метод отправит электронное письмо об ошибке.

Код: Выделить всё

   @Bean
public IntegrationFlow sampleHasErrorFlow() {
return IntegrationFlows.from(fileReadingMessageSource())
.publishSubscribeChannel(s -> s
.subscribe(f -> f
.handle("sampleBean", "methodThatThrowsException")
.channel(filesProcessedChannel())))

.get();
}

Я просто хочу «перехватить» исключение, созданное в методе ThatThrowsException(). Может ли кто-нибудь предоставить быстрый образец?

Подробнее здесь: https://stackoverflow.com/questions/784 ... ntegration