2017-01-04 15 views
0

В настоящее время я использую tMomInput для чтения из Active MQ. Есть ли способ в Talend, который мы можем читать из очереди в Active MQ без удаления? Можно ли удалить содержимое только тогда, когда оно успешно скопировано во временную таблицу? Если произошел сбой, например, завершение работы сервера и сбой задания, прежде чем копировать их в таблицу БД, тогда невозможно восстановить данные.Как читать из Active MQ без удаления содержимого в Talend

ответ

0

Общий способ сделать это в JMS - использовать транзакции. Таким образом, сообщение удаляется только из очереди, когда транзакция фиксируется в случае успеха. В случае ошибки транзакция откатывается назад, и сообщение возвращается на сервер jms для повторной передачи.