У меня возникла проблема с 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
Захват цикла Camel Framework ⇐ JAVA
Программисты JAVA общаются здесь
1710407256
Гость
У меня возникла проблема с 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
Источник: [url]https://stackoverflow.com/questions/78156915/camel-framework-loop-capture[/url]
Ответить
1 сообщение
• Страница 1 из 1
Перейти
- Кемерово-IT
- ↳ Javascript
- ↳ C#
- ↳ JAVA
- ↳ Elasticsearch aggregation
- ↳ Python
- ↳ Php
- ↳ Android
- ↳ Html
- ↳ Jquery
- ↳ C++
- ↳ IOS
- ↳ CSS
- ↳ Excel
- ↳ Linux
- ↳ Apache
- ↳ MySql
- Детский мир
- Для души
- ↳ Музыкальные инструменты даром
- ↳ Печатная продукция даром
- Внешняя красота и здоровье
- ↳ Одежда и обувь для взрослых даром
- ↳ Товары для здоровья
- ↳ Физкультура и спорт
- Техника - даром!
- ↳ Автомобилистам
- ↳ Компьютерная техника
- ↳ Плиты: газовые и электрические
- ↳ Холодильники
- ↳ Стиральные машины
- ↳ Телевизоры
- ↳ Телефоны, смартфоны, плашеты
- ↳ Швейные машинки
- ↳ Прочая электроника и техника
- ↳ Фототехника
- Ремонт и интерьер
- ↳ Стройматериалы, инструмент
- ↳ Мебель и предметы интерьера даром
- ↳ Cантехника
- Другие темы
- ↳ Разное даром
- ↳ Давай меняться!
- ↳ Отдам\возьму за копеечку
- ↳ Работа и подработка в Кемерове
- ↳ Давай с тобой поговорим...
Мобильная версия