Отказоустойчивость при чтении с FTP-сайтов с использованием Camel

Question

Нам необходимо загрузить несколько файлов по часам с FTP-сайта поставщиков. Поставщик предоставляет два ftp-сайта для отказоустойчивости на обоих сайтах, имеющих одинаковые файлы. Я хотел бы настроить маршрут Camel для загрузки файлов с ftp-сайта A, если он доступен, и если не попробовать ftp-сайт B. Следующий код неверен, но он может выделить то, что я пытаюсь достичь.

from("timer://timer1?fixedRate=true&period=60m") 
     .loadBalance() 
     .failover(-1, false, true) 
     .to("direct:ftp-symbolguides-1") 
     .to("direct:ftp-symbolguides-2") 
    .end(); 

    from("direct:ftp-symbolguides-1") 
     .to("ftp://SiteA?localWorkDirectory=c:/temp&passiveMode=true&noop=true&idempotentKey=${file:name}-${file:size}&idempotentRepository=#idempotentRepository") 
     .to("file:/c:/temp/inbox"); 

    from("direct:ftp-symbolguides-2") 
     .to("ftp://SiteB?password=publicftp&localWorkDirectory=c:/temp&passiveMode=true&noop=true&idempotentKey=${file:name}-${file:size}&idempotentRepository=#idempotentRepository") 
     .to("file:/c:/temp/inbox"); 

Есть ли у кого-нибудь мысли о том, как я могу это достичь?

Answer 1

Когда не удается установить соединение по протоколу FTP по умолчанию потребитель производит сообщение WARN вместо того, чтобы выбросить исключение, но по throwExceptionOnConnectionFailed собственности вы можете изменить, чтобы бросить исключение и обработать исключение из метода PollingConsumerPollStrategy [1] Откат().

http://camel.apache.org/maven/current/camel-core/apidocs/org/apache/camel/spi/PollingConsumerPollStrategy.html