Захват цикла Camel FrameworkJAVA

Программисты JAVA общаются здесь
Ответить
Гость
 Захват цикла Camel Framework

Сообщение Гость »

У меня возникла проблема с cronjob в верблюжьей среде
Я пытаюсь обработать исключение в случае возникновения ошибки, но оно выдает следующую ошибку
вызвано: org.apache .camel.NoSuchEndpointException: не удалось найти конечную точку для: cronJob, проверьте, что ваш путь к классам содержит необходимый jar-файл компонента Camel.
Не могли бы вы подсказать, откуда возникла проблема
##Cronjob
apache.cronjob=timer://runOnce?repeatCount=1
from("cronJob")
.log("Cronjob started. Contacting Isabel API.")
.bean(CollectReportsProcessor.class)
.log("** Looplength of cronjob: ${headers.looplength}")
.loop(header("looplength"))
.choice()
.when(simple("${header.CamelLoopIndex} == 3"))
.log("Loop CamelLoopIndex is more than 3. Exiting the route.")
.stop() // Stop the route if loop length is less than 1
.end()
.bean(ToSftp.class)
.log("Picking up account reports and sending them to sftp.")
.log("**** Filename : ${headers.CamelFileName} Format: ${headers.FileFormat}")
.log("Only CAMT-files are picked up, others will not be sent to BBS import")
.choice()
.when(header("FileFormat").contains("CAMT53")) // (is CAMT)
.doTry()
.marshal().pgp(PGP_EQUO_PUBLIC_PATH, PGP_EQUO_USERID)
.multicast()
.to(BBS_SERVER)
.log("Message sent to BBS_SERVER")
.to(KYRIBA_BANK_STM_OUT)
.log("Message sent to KYRIBA_BANK_STM_OUT")
.bean(StatusUpdateProcessor.class)
.endDoTry()
.doCatch(Exception.class)
.process(exchange -> {
statusUpdaterProcessor.processWithRetry(exchange);
exchange.setProperty(Exchange.ROUTE_STOP, true);
})
.log("Failed to send message to BBS_SERVER. Retrying... ${headers.retryCount}")

.endChoice() // End of (is CAMT)
.choice()
.when(PredicateBuilder.or(
header("FileFormat").contains("COD"),
header("FileFormat").contains("940")
)) //(is COD or 940)
.doTry()
.marshal().pgp(PGP_EQUO_PUBLIC_PATH, PGP_EQUO_USERID)
.log("MT940/COD file detected. Further processing to Kyriba.")
.to(KYRIBA_BANK_STM_OUT)
.log("Message sent to KYRIBA_BANK_STM_OUT")
.bean(StatusUpdateProcessor.class)
.endDoTry()
.doCatch(Exception.class)
.process(exchange -> {
statusUpdaterProcessor.processWithRetry(exchange);
exchange.setProperty(Exchange.ROUTE_STOP, true);
})
.log("Failed to send message to KYRIBA_BANK_STM_OUT. Retrying... ${headers.retryCount}")
.endChoice() // End of (is COD or 940)
.endChoice() // End of inner choice
//.bean(StatusUpdateProcessor.class)
.end(); // End of route


Источник: https://stackoverflow.com/questions/781 ... op-capture
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»