JMS Commit между маршрутами - я хочу зафиксировать транзакцию между маршрутами в Camel - PullRequest
0 голосов
/ 29 августа 2018

Я использую транзакцию JMS на верблюде

У меня есть два маршрута

from("jms:queue:test).process(new Processor(Exchange exchange){
   //place the message to hdfs
   //using hadoop fs api
}).to("direct:ssh")

from("direct:ssh").to(sshCommand)

я хочу после отправки сообщения по прямому ssh-маршруту зафиксировать транзакцию JMS. Не ждите прямого результата ssh.

В настоящее время транзакция фиксируется только тогда, когда моя команда ssh выдает результат. Возможно ли зафиксировать значение между

Заранее спасибо.

1 Ответ

0 голосов
/ 29 августа 2018

Мне удалось выполнить описанную выше операцию вместо прямого, я использовал seda

from("jms:queue:test).process(new Processor(Exchange exchange){
   //place the message to hdfs
   //using hadoop fs api
}).to("seda:ssh")

from("seda:ssh").to(sshCommand)
...