Apache Camel: как сделать XA Transactional Manager в маршруте с FTP-конечной точкой и доступом для записи в базу данных?

Question

Это маршрут:

from(jms:queue:xxx)
...
.process(_write_in_db_)
...
.to(ftp:yyy)

Я думаю, что мне нужен глобальный XA Transactional Manager , который охватывает весь маршрут и фиксирует изменения в БД и очереди только после глобальной фиксации.

К сожалению, я не нашел примеров для этого случая и был бы признателен, если бы кто-нибудь мог сказать, как это сделать.

Answer 1

Отличный пример @ https://github.com/FuseByExample/esb-transactions.Я лично использовал этот пример в качестве отправной точки, и он отлично работает.

Изучая этот пример, вы узнаете:

Как настроить источник данных с поддержкой XA

Как настроить модуль сохранения JPA

Как использовать поддержку Fuse ESB JTA и JPA в ваших маршрутах

Как настроить компонент JMS для поддержки XA

Какопределить маршрут транзакции

Как настроить ResourceManager, который может восстанавливать транзакции XA после сбоя