Популярные вопросы по тегу APACHE-CAMEL

Apache Camel - запуск задачи при запуске для однократного запуска

... остроение всех маршрутов. Мы 9 не можем вызвать метод во время создания 8 класса, поскольку он имеет динамические 7 связи с другими классами, которые он берет 6 из аннотации @Component spring, и мы не 5 знаем, когда / были ли загружены эти классы, чтобы 4 фактически запустить метод инициализации 3 как часть конструктора. Как я могу вызвать 2 метод или методы для запус ...

Тестирование Camel с помощью MockEndpoints

... взаимодействовать с этими конечными 2 точками: @Test public final void processMethodShouldSendToOutputQueue() { Component comp = new Component(); comp.process(); outputQueue.assertIsSatisfied(); } Я просто не понимаю, как все правильно 1 подключить: Как подключить comp к точкам inputQueue и outputQueue MockEndpoints? Для каждого MockEndpoint, как настроить ожидания, чтобы assertIsSatisfied() проверял, присутств ...

Добавить маршрут верблюда во время выполнения в Java

... еделенных статических 7 маршрутов, и я хочу добавить к нему несколько 6 динамических маршрутов во время выполнения. Является 5 ли это возможным? Потому что единственный 4 способ включить динамический маршрут - это 3 написать route.xml и затем загрузить определение 2 маршрута в ко ...

Как получить код статуса ответа после HTTP-вызова верблюда

... l. Я выполняю вызов 3 https4 с верблюжьего маршрута. Я хочу получить 2 к ...

Apache Camel: конечная точка "direct: start" - что это значит?

... mel. Может кто-нибудь 2 объяснить, что означает «прямой: запуск» в 1 Camel. См. https://camel.apache.org/components/latest ...

Функции модульного тестирования с Apache Camel Exchange в качестве параметра

... ty from xml message in exchange via xpath } Вопрос: 1> Могу ли я 7 использовать EasyMock для имитации Exchange? А 6 как установить предопределенный xml как 5 входящее сообщение внутри обмена? 2> Если 4 нет, мне нужно настроить тест на верблюда? Как 3 установить предопределенный xml в качестве 2 входящего сообщения внутри обмена с помощью ...

Отправить запрос POST с помощью Apache Camel

... аюсь 5 отправить запрос POST с телом JSON с помощью 4 Apache Camel. Я не смог понять, как добавить ...

Как я могу зарегистрировать значение заголовка в Camel с помощью Spring DSL

... обовал: <log message="ftping $simple{header.CamelFileName}"/> а также: <log message="ftping ${header.CamelFileName}"/> и несколько других 5 перестановок / вариантов, но все они просто 4 дословно записывают этот текст (т.е. они 3 не заменяют фактическое имя за ...

Что такое Apache Camel?

... могли дать представление о Camel в 101 1 слове: Что именно? Как он взаимодействует с приложением, напис ...

Apache Camel против Apache Kafka

... ил эту задачу? Само приложение 10 будет работать на сервере WebLogic в любом 9 случае. Обмен сообщениями будет осуществляться 8 по типу «точка-точка», когда будет запущено 7 несколько экземпляров одной и той же службы, но 6 только один экземпляр должен обработать 5 сообщение и выдать результат в соответствии 4 с политикой балансировки нагрузки. Очереди 3 сообщений также кластеризованы, поэтому 2 ни сбой экземпляра службы, ни ...

Apache camel для агрегирования нескольких ответов службы REST

... хочу вызвать эти две конечные 4 точки REST (callA и callB) -> получить их 3 ответы - resA и resB -> объединить их в 2 один объект ответа resScan -> вернуться 1 к клиенту. Все, что у меня сейчас есть - <route id="MyServiceScanRoute"> <from uri="jetty:http://{host}.{port}./my-service/scan/?matchOnUriPrefix=true&bridgeEndpoint=true"/> <!-- Set service specific headers, monitoring etc. --> <!-- Call perform ...

Как преобразовать JSONArray в список объектов с помощью camel-jackson

... рока массива json, как показано 7 ниже {"Compemployes":[ { "id":1001, "name":"jhon" }, { "id":1002, "name":"jhon" } ]} я хочу преобразовать этот jsonarray 6 в List<Empolyee>. для этого я добавил зависимость maven 5 «camel-jackson», а ...

Exchange.getIn(). GetBody() возвращает пустую строку в верблюде при втором вызове

... ие обмена In должно остаться 7 нетронутым. Пожалуйста, объясните, почему 6 это происходит. Верблюжьи маршруты: <camelContext xmlns="http://camel.apache.org/schema/spring"> <route id="route1"> <from uri="timer://myTimer?period=2000" /> <setBody> <simple>Hello World ${header.firedTime}</simple> </setBody> <process ref="messageProces ...

Зарегистрируйте тело обмена верблюда в виде строки с помощью log4j

... uri="log:com.javarticles?level=INFO"/> но он не записывается как 3 строка 15:09:05,403 | INFO | qtp938841692-57 | javarticles | 198 - org.apache.camel.camel-core - 2.15.1.redhat-620133 | Exchange[ExchangePattern: InOut, BodyType: java.lang.String, Body: org.apache.cxf.ja ...

Рабочий процесс в Camel против BPM

... ньше 9 шансов поработать над продуктом BPM, таким 8 как JBOSS BPM и т. д. Помимо длительного 7 срока службы и поддержки человеческих задач, есть 6 ли еще какая-либо веская причина, по которой 5 мы должны выбрать продукт BPM? Если в нашем 4 проекте не требуется и долгосрочная поддержка ...

Как в Camel динамически добавлять и запускать маршруты?

... 7 TemplateEndpoint.generateRoute (добавление определений маршрута) вызывается 6 из StartupListener (определено в TemplateEndpoint.setSuffix). Таким образом, при 5 запуске контекста Camel определения маршрутов 4 появляются в контексте, но фреймворк не 3 создает для них сервисы маршрутов, и, следовательно, они 2 не запускаются. Как начать маршруты, добавленные 1 в StartupListener? Вероятно, я столкнул ...

Apache-camel: включение bridgeEndpoint на конечной точке http

... rocessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61) at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:448) at org.apache.camel.processor.CamelInternalProcessor.process(Camel ...

Apache Camel: как получить сообщение об исключении внутри блока doCatch()?

... гается использовать .transform(simple?...) .handled(true), но 2 большая его часть устарела. Как правильно 1 это сделать? Ответ: <418 I'm a teapot,simple{${exception.message}},{}> Маршрут from("direct:csv") .doTry() .process(doSomeThingWithTheFileProcessor) .doCatch(Exception.class) .process(e -> { e.getOut().setBody(new ResponseEntity<String>(exc ...

Как определить исключение, которое будет выброшено через ref в Apache Camel

... которое выглядит 8 так: <throwException ref="forced"></throwException> Однако я не знаю, как определить генерируемый 7 класс исключения forced. Поскольку одно и то же 6 исключение может быть сгенерировано неско ...

Передача значений между процессорами в apache camel

... сохранение его в заголовках обмена с помощью метода setProperty при построении маршрута. другой способ . ...

Компонент не найден с ошибкой схемы http в apache camel

... ) { from("direct:start") .setHeader(Exchange.HTTP_METHOD,simple("GET")) .to("http://10.10.10.10:8080/RestfulDemo/rest/get"); } }); context.start(); ProducerTemplate template = context.createProducerTemplate(); String headerValue = "application/xml"; Map<String, Object> headers ...

Camel end vs endChoice - необычный запрос

... mel разберется 21 с этим, но мне нравится, чтобы блоки были 20 четко очерчены, если только нет причин не 19 использовать их. .choice() .when(X1) // do stuff .choice() .when(Y) //do more stuff .endChoice() // close inner when block .end() // close inner choice block .endChoice() // close first outer when .when ...

Как настроить Jackson ObjectMapper для Camel в Spring Boot

... аршрута входящего сообщения: @Component public class MyRouteBuilder extends RouteBuilder { @Autowired private MyBean myBean; @Override public void configure() { from(uri) .unmarshal().json(JsonLi ...

Stacktrace из контекста Camel onException

... исключение, а не всю 5 трассировку стека. Я понимаю, что Camel сохраняет 4 перехваченное исключение как свойство на 3 Exchange с ключом: Exchange.EXCEPTION_CAUGHT, но 2 как это можно получить из файла маршрутов 1 ...

getIn() против getMessage() обмена в apache.camel

... ет текущее 3 сообщение. Мой вопрос: когда входящее сообщение 2 не изменяется в текущем процессоре, возвращает 1 ли getIn() ...

Создает ли верблюд поток для каждого маршрута

... работающее 12 ни в одном контейнере), в котором я определил 11 два маршрута: route1: переместить файл из 10 входящей папки1 в папку2 route2: переместить 9 содержимое файла из folderx в очередь mq. Я 8 запускаю свое приложение, и эти маршруты 7 выполняют свою работу, опрашивая эти папки 6 и соответствующим ...

КАК: файлы соответствия Apache Camel, Regex

... <route id="SVLFTPCOPY"> <from uri="sftp://*****:*******@********/srv/test/?fileName=*2280.xls&noop=true&idempotent=false"/> <to uri="file:/srv/data/test/destination/"/> <to uri="activemq:queue:svl.ftp.copy"/> </route> он работает до 3 точки, где он запускает м ...

Camel - обогащение контента: enrich() vs pollEnrich()

... ); Object mergeResult = ... // combine original body and resource response if (original.getPattern().isOutCapable()) { original.getOut().setBody(mergeResult); } else { original.getIn().setBody(mergeResult); } return original; } } В этом 5 примере я вижу, что у них есть доступ к 4 Exchange original, разве это не «тек ...

Весенняя загрузка и тестирование верблюда с @SpringBootTest

... d simpleTest() throws Exception { mockEndpointOut.expectedMessageCount(1); producerTemplate.sendBody("Test"); mockEndpointOut.assertIsSatisfied(); } @Override protected RoutesBuilder createRouteBuilder() throws Exception { return new MyRoute(); } } Когда 8 я запускаю этот тест, он работает нормально, я 7 получаю одно сообщение, и конечная точка 6 удовлетворена. Если я добавлю аннот ...

Camel - кеш потока не кешируется / не может конвертироваться?

... org.apache.camel.converter.stream.InputStreamCache -> java.lang.String with value: org.apache.camel.converter.stream.InputStreamCache@780a5cef 6- TRACE org.apache.camel.impl.converter.DefaultTypeConverter : Using converter: StaticMethodTypeConverter: public static java.lang.String org.apache.camel.converter.IOConverter.toString(java.io.InputStream,org.apache.camel.Exchange) throws java.io.IOExceptio ...

Не удалось найти конечную точку для: direct: // DistributeOrderXML, убедитесь, что ваш путь к классам содержит необходимый jar-компонент Camel

... icationEventMulticaster.java:139) в 20 org.springframework.context.support.AbstractApplicationContext.publishEvent 19 (AbstractApplicationContext.java:403) в 18 org.springframework.context.support.AbstractApplicationContext.publishEven ...

Производители и потребители Apache Camel

... ть конечную точку, которая прослушивает 14 порт TCP для входящих сообщений в проприетарном 13 формате, который затем преобразует сообщение 12 и верблюд берет на себя пересылку и маршрутизацию. Правильно 11 ли я понял, что производитель отвечает за 10 отправку сообщений в Endpoint, а Consumer получает их с 9 этой конечно ...

Конечная точка макета Apache Camel

... , и есть много примеров, где 5 часть маршрута «до» записывается как <route id="person-add-route"> <from uri="direct:start"/> <to uri="mock:result"/> </route> Итак, я 4 написал тест, в котором ожидаю использовать 3 mock: result в качестве последнего конечного ...

Camel - Как установить свойство с помощью шаблона производителя?

... дителя? Представьте 12 себе конечную точку отдыха, которая принимает 11 заказы от клиента (еще не на верблюжьем 10 маршруте). Используя шаблон производителя, я 9 хотел бы установить свойство client-id на бирже. использовать его позже, когда потребуется на маршруте. Да, я также могу использовать заголовки 8 и Prod ...

Что такое статус CrashLoopBackOff для модулей openshift?

... ь и запустить его локально 6 (без openshift), но когда я пытаюсь развернуть 5 его на своем локальном openshift (используя 4 mvn -Pf8-local-deploy), я получаю этот вывод для этого конкретного 3 примера (вырезано для актуальности): - [vagrant@vagrant camel]$ oc get pods NAME READY ...

Apache Camel: errorHandler против onException?

... <camel:camelContext errorHandlerRef="deadLetterErrorHandler"> ... </camel:camelContext> И: <onException> ... </onException> Согласно this article, их совместное 3 использование является " ...

Как сбросить тело HTTP и заголовки, отправленные с HTTP-компонентом, с помощью Apache Camel

... TP_QUERY, constant("q=${q}&wt=xml")). setHeader(Exchange.CONTENT_TYPE, constant('application/xml')). setHeader(Exchange.HTTP_METHOD, constant('GET')). se ...

Исключение с использованием библиотеки Jackson JSON с верблюдом

... </groupId> <artifactId>jackson-jaxrs</artifactId> <version>1.9.13</version> </dependency> Вот мое 6 определение объекта Dataformat: <bean id="jsonDataformat" class="org.apache.camel.model ...

Когда использовать Spring Integration против Camel?

... а запрос-ответ (прослушивание 10 различных очередей JMS). Поэтому я искал 9 некоторую справочную информацию о том, чем 8 Camel отличается от Spring Integration, но, похоже, информации 7 там довольно мало, я обнаружил: http://java.dzone.com/articles/spring-integration-and-apache (Очень нейтральное сравнение между реализацией реального сценария интеграции в Spring Integration и Camel, с декабря 2009 г.) http://hillert.blogspot.com/2009/ ...

Apache Camel: как сохранить переменную для дальнейшего использования

... ьзованием Spring 18 DSL, я столкнулся со следующей проблемой. Предположим, ожидаемый 17 поток сообщений выглядит следующим образом: клиент отправляет сообщение HTTP POST с телом XML в CAMEL CAMEL отправляет сообщение HTTP POST на сервер, при этом URI слегка адаптирован с использованием информация из полученного тела XML (например: используйте XPATH для фильтрации определенного параметра) после того, как CAMEL получил ответ, CAMEL отправ ...

Camel - передача определенных параметров из маршрутов в универсальный метод bean-компонента

... ublic class MyBean { public void beanMethod(String headerExpected) { // do something with the value here. } } По сути, я хочу передать значение 4 someHeader из myRoute в beanMethod в MyBean. Зная, что beanMethod может принимать 3 String, как я могу передать значение ...

Camel rabbitmq + convertSendAndReceive(): не удалось преобразовать входящее сообщение с типом содержимого [null]

... 8 rabbitmq.DELIVERY_TAG=4 rabbitmq.EXCHANGE_NAME= rabbitmq.PRIORITY=0 rabbitmq.REPLY_TO=amq.rabbitmq.reply-to.g2dkABNyYWJiaXRAOWU5ZjkxNDI4ZWRiAAAJgwAAADUC.5+kPXXxaXhoYo7A4T0HSZQ== rabbitmq.ROUTING_KEY=testQ Заголовок 4 сообщения, по-видимому, содержит rabbitmq.CONTENT_TYPE = application / json на рабочей 3 стороне, но эта информация, похоже, «теряется», когда 2 ответное сообщение возвращается: o.s.a.s.c.Jackson2JsonMes ...

Как демаршалировать тело json в список myclass в camel

... rom("direct:testroute") .log("Received body ${body}") .unmarshal().json(JsonLibrary.Jackson, List.class) И я бы хотел что-то вроде 1 (тоже явно не работает) from("direct:testroute") .log("Received body ${body}") .unm ...

Как реализовать повтор попытки по таймауту в Camel?

... .to("seda:jmsRequestToExternal"); Чтобы добиться низкой 8 задержки, все маршруты / суб-маршруты не 7 должны блокировать друг друга. Хотелось 6 бы понять, есть ли лучшая реализация, способная 5 добиться того же? Насколько я понимаю ...

Чтение закрытого ключа SSH из файла application.yaml при весенней загрузке?

... throws IOException { InputStream input; input = new FileInputStream(new File(filename)); ByteArrayOutputStream output = new ByteArrayOutputStream(); IOHelper.copyAndCloseInput(input, output); return output.toByteArray(); } Я 13 хо ...

Как запустить Spark-submit удаленно?

... еня работает искра в кластере (удаленный) Как 7 отправить заявку с помощью spark-submit 6 в удаленный кластер со следующим сценарием: spark-submit 5 выполняется как команда через camel приложение 4 работает в собствен ...

Camel читает содержимое файла

... (или построчно) в верблюде 2 без написания конвертера или какого-либо 1 java-кода ...

Как транзакционно опросить Kafka из Camel?

... оторый 29 выглядит следующим образом: ` <route id="station-event-enrich-route" autoStartup="true" > <from uri="kafka:{{kafka.cluster.url}}?brokers={{kafka.cluster.url}}&topic={{events.topic.name}}&autoCommitEnable=false&allowManualCommit=true&maxPollRecords={{station.brocker.bulk.limit}}&grou ...

Верблюд - использование end()

... d2") и это 1 тоже, from("jms:some-queue") .beanRef("bean1", "method1") .beanR ...

Apache Camel Http и SSL

... lient.AbstractHttpClient.execute(AbstractHttpClient.java:732) at org.apache.camel.component.http4.HttpProducer.executeMethod(HttpProducer.java:187) at org.apache.camel.component.http4.HttpProducer.process(HttpProducer.java:101) at org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBridge.process(AsyncProcessorTypeConverter.java:50) at org.apache ...