I want to have a base RouteBuilder class that would allow using an optional Custom Processor. If a child class has it specified, then add it to the route otherwise don't. I have been trying to use the choice() when()…
I have IIS FTPS Server setup and am trying to connect from a Camel route. But I'm getting the error: 22 Sep 2019 08:59:51,650 | WARN | Camel (Test) thread #202 - ftps://test@test1834:21/BO/Salary | FtpConsumer | 248 - org.apache.camel.camel-core -…
I need to return the message from a thrown exception, or put it in the outmessage. But it does not print the correct message on the frontend. The camel docs suggest using .transform(simple?...) .handled(true) but most of it is deprecated.…
I have a processor with below code ProducerTemplate.sendBodyAndProperty("direct:endpoint", body, property, propertyValue) I need to use propertyValue in the below route() <route> <from uri="direct:endpoint" /> <to uri="file:/?fileName=${propertyValue}" /> </route> Please advice
I need some help with update of exchange property in Apache Camel. Use case: I have route which gets some Ids from API endpoint, after that i need to get info for every id from another endpoint. I need to…
I am creating a simple file transfer utility where based on user input I search the file in the folder and transfer the matched file to destination. The problem is camel is moving all the files which are not matching…
How to set default data format for a component in Apache Camel? I have a number of routes interacting with different ActiveMQ queues. At the moment all of them look like from("...") .process(...) .marshal().json() // (1) .to("activemq:queue:..."); or from("activemq:queue:...") .unmarshal().json()…
I have 2 endpoints that I would like to establish routes between. Due to the nature of these endpoints (JMS topics), I would like the bridging to be bidirectional. The underlying JmsComponent for the Tibco endpoint has the pubSubNoLocal parameter…
I have this scenario: ADDRESS1: -ADDRESS1.QUEUE1 -ADDRESS1.QUEUE2 ADDRESS2: -ADDRESS2.QUEUE1 -ADDRESS2.QUEUE2 Two addresses with multiple anycast queues. I need to route messages to a specify queue into the address. Example: Messages on ADDRESS1::ADDRESS1.QUEUE1 goes to -> ADDRESS2::ADDRESS2.QUEUE1 Messages on ADDRESS1::ADDRESS1.QUEUE2 goes…
If my understanding is correct, then camel routes do not have a 'complete' state therefore it doesn't make sense to say something like camelContext.addRoute(route1); camelContext.start(); while(0) { ifComplete(route1) break; } camelContext.stop(); and in most examples I've seen it is written…