2022-12-14 14:04:56,317 DEBUG [org.apa.cam.com.jms.EndpointMessageListener] (Camel (camel-1) thread #8 – JmsConsumer[my.queue]) activemq://queue:my.queue consumer received JMS message: ActiveMQTextMessage {commandId = 13, responseRequired = true, messageId = ID:xxxx, originalDestination = null,…, …
Tag: apache-camel
How to use the XML Tokenize language as a predicate in a Content based Router?
Can we use body().xtokenize as predicate of choice() in Camel pipeline for routing when XML type matches the path we want? I tried it but doesn’t filter in accordance with the predicate : This is the code snippet : These are the type of XML content that I would like to route according to the name of the…
Camel – Acknowledgement management with spring-rabbitmq
I am trying to write a simple consumer for a rabbitMQ queue on which a DLX (binded to another queue is configured). I am using camel 3.14.5 at the moment. My camel route declaration looks like : And my connectionFactory : But then when my processor throw an exception I get the following logs : How should I co…
RouteBuilder with multiple routes
I am using a route builder in my Camel Context like this: I have implemented a RouteBuilder like this: Is it possible to implement more routes in the same route builder? Answer yes you can implement a lot of routes in the same route builder like this, I advise you to use routeId for identify the route in the …
Camel Quarkus ClassNotFoundException: HttpOperationFailedException
I have a Quarkus app that uses Apache-Camel and runs fine locally. When I build it and try to run the docker container then I get the following error: My gradle dependencies are } When I run it with “quarkus dev” in IntelliJ Terminal I have no problems. Do I try to run the container I get the erro…
Apache Camel: access Route after polling
I’m using Camel JPA endpoints to poll a database and copy the data to a second one. To not poll duplicates, I’m planning to save the highest ID of the copied data and only poll data with an ID higher than that one. To save a few database writes, I want to write back the highest ID after the curren…
copy file to multiple folders with Camel SFTP
I have a situation where I pull a file from a folder via a Camel SFTP route. There are 3 other Camel routes which need to process the same file which I am pulling… the other routes monitor the same SFTP server. Currently, we are thinking that we should make that file which I pull, available to the 3 oth…
Configure Apache Qpid JMS (jakarta.jms) connectionfactory in Apache Camel XML DSL in AMQP component
Trying to use the jakarta.jms Apache Qpid AMQP client to process messages. I am trying to use poolable connection factory using org.messagehub. Standlone java code works, refer the java changes. When I try use the same in Spring XML DSL in Camel, the AMQP component doesn’t support the jakarta.jmx connec…
How to add Camel properties component to camel context?
I’m currently trying to add properties component with location set to my properties file to use properties placeholders in my project: But addComponent() function expects Component type argument, not PropertiesComponent even though PropertiesComponent extends the DefaultComponent class. I’ve added…
Why my REST api created with camel servlet doesn’t expose?
I’m currently struggling with exposing the REST api in my project using Apache Camel. When I run the project it seems to be fine in the console, but it just doesn’t work: curl http://127.0.0.1:8080/materials curl: (7) Failed to connect to 127.0.0.1 port 8080: Connection refused Here’s the po…