Spring Integration: обработка ошибок для исходящего адаптера Jpa ⇐ JAVA

[Гость]

У меня есть поток интеграции Spring, который использует Jpa.inboundAdapter() в качестве источника, манипулирует прочитанными объектами в преобразовании и, наконец, сохраняет их снова с помощью Jpa.outboundAdapter.

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

Как правильно выполнить обработку ошибок, чтобы отметить или пропустить «плохие» объекты, считанные из источника?

Поток:
IntegrationFlows .от( Япония .inboundAdapter(entityMaanger) .entityClass(...) .nameqQuery(...) .получать() ) .расколоть() .трансформировать( ..) .ручка( Япония .outboundAdapter(entityManager) .entityClass(...) .persistMode(СЛИЯНИЕ) .flush(истина) .получать(), е -> e.transactional()) ) );