Прерывание потока трансформатора Пружинная интеграция

Question

у меня пружины интеграции потоков.Один для файлового опроса, другой - для обработки файла

flow # 01

опрос файла в каталоге C: / testing

файлыприходит идет в очередь «процесса»

flow # 02 (из «процесса»)

Transformer(new FindTheDepartItbelongs()) //basically file has to match to some depoartment
.transform(new FileParserTransformer()
.transformer(new CustomerTransformer()
.handle (o -> {})

Проблема в том, что FindTheDepartItBelongs не может найти отделон должен остановить остальную часть потока и отправить сообщение в некоторую очередь ошибок.

Если я возвращаю нулевое значение из преобразователя, это не работает.

Есть ли другой способ достижениятакой же?

Answer 1

Преобразователь не может вернуть ноль, но метод .handle () может и поток просто останавливается.Это не пойдет на канал ошибок, хотя;Вы должны бросить исключение для этого.