Extend CronScheduledRoutePolicy

Hi I configured a route with CronScheduledRoutePolicy to stop every afternoon at 6pm and start the following morning again at 4am (because a downstream system is not available). Works fine so far. Now, what if my component is deployed at 8pm? The route starts, the cron trigger is already pass

AW: Access native KafkaConsumer in Camel RoutePolicy

get hold on the consumer which you can cast to KafkaConsumer (Camel's) and then with the new pause/resume api use that. On Mon, Aug 24, 2020 at 9:02 AM Burkard Stephan wrote: > > Hi > > **I also posted this question on StackOverflow** => > https://stackoverflow.com/q/6

Access native KafkaConsumer in Camel RoutePolicy

Hi **I also posted this question on StackOverflow** => https://stackoverflow.com/q/63519628/8035582 I "monitor" the number of consecutive failures in my Camel processing pipeline with a Camel RoutePolicy. When a threshold of failures is reached, I want to pause the processing for a configur

Camel-Kafka Producer Problem

Hi I have built a tiny example project to demonstrate a problem of camel-kafka component I stumbled upon. When a Kafka producer is used in a global exception handler, typically to route error messages to a dead letter topic, the producer is registered at the broker for every route. Are the

AW: [ANNOUNCEMENT] Brand new Apache Camel website

Fantastic work, congratulations! As Willem already mentioned, it is a bit annoying that the old links are no more working. Google will soon be updated, but all the documentation links on Stackoverflow and in the Mailing list archive are dead. It would be very nice if there were webserver redir

AW: Help Needed: Splitter and Parallel Processing

Hi OK, here is my wild guess :-) Based on your log output I suspect the following: 1. It starts and finds 33 instances to process 2. After processing the second instance, there is a problem 3. Could be that the log output "Handled one of: [..]" instead of "Handled one of: model.Instance" is a

AW: InOut exchange pattern on Transactional JMS endpoint not working

Hi sujin sr 1. Don't worry, Camel is automatically copying the headers for you. Just send the message on to the replyQueue .from("activemq:queue:DataRequestQueue") .to("activemq:queue:DataReplyQueue") 2. Not sure if I understand you correct: you mean how can each sender (if there are multiple)

AW: [DISCUSS] - Apache Camel 3 - A new tagline

Hi all +1 for "Integrate everything!" because it is short, catchy and it refers to Camels outstanding versatility with its hundreds of components. It is true that Camel has a lot of other noteworthy features like runtime flexibility etc. but as soon as the tagline wants to cover multiple thing

AW: New Camel logo

with/without the name etc https://github.com/apache/camel/tree/master/docs/img On Thu, Jun 7, 2018 at 3:25 PM, Burkard Stephan wrote: > Hi > > Is the logo in this post the new Camel logo? > http://www.davsclaus.com/2018/03/apache-camel-221-released-whats-new.html > > I just stum

New Camel logo

Hi Is the logo in this post the new Camel logo? http://www.davsclaus.com/2018/03/apache-camel-221-released-whats-new.html I just stumbled upon this and then I remembered there was kind of a contest for a new logo and a voting, but I never heard about any final result of the whole thing. And o

AW: MockEndpoint does not receive message if error occures in subroute

sertPeriod(1000); template.sendBodyAndHeaders("direct:input", "This messages produces an error in the choice/when block", headers); assertMockEndpointsSatisfied(); } } > On Jan 3, 2018, at 6:44 AM, Burkard Stephan wrote: > > Thanks Quinn. > > &

AW: MockEndpoint does not receive message if error occures in subroute

ing up the exception from the call to the direct://Validate route. If you add ".errorHandler(new NoErrorHandlerBuilder())” to the direct://Validate route, your test will pass. Quinn Stevenson qu...@pronoia-solutions.com<mailto:qu...@pronoia-solutions.com> (801) 244-7758

AW: Camel Clustering

Hi, For JMS you can simply deploy multiple instances of your module and then they concurrently consume messages from the same queues (not round robin, but parallel processing. No zookeeper needed). Notice that even a single instance can have multiple concurrent consumers. For file endpoints

AW: Peek into big file before splitter

with the original message body as-is. It would be a different story if the message body was an InputStream that was only readable once. For that you can use stream caching from Camel. On Fri, Dec 15, 2017 at 4:48 PM, Burkard Stephan wrote: > Hi Camel users > > I have a route that

Peek into big file before splitter

Hi Camel users I have a route that consumes big XML files (100 to 300 MB), splits them into chunks and processes the chunks. from(pollingFileConsumer) .routeId("bigFileConsumer") // here I would like to make a very basic check if the file looks as expected .split().tokenizeXML("Xm

AW: Camel FTP polling is very slow

Hi I think "readLockCheckInterval=1000" means that the process waits 1 second for EVERY FILE to check the read-lock. So you would get a throughput of less than 1 file per second. Do you mean that with slow? Regards Stephan -Ursprüngliche Nachricht- Von: chandresh pancholi [mailto:cha

XML validation with Camel (multiple XSDs)

Hi I have a use case where multiple different XML schema files exist (for different types of messages or schema versions). Whenever a message arrives, I have to validate it against the correct schema. The correct schema is derived from the message namespace. ==> use A.xsd ==> use B.xs

AW: AdviceWith in test not followed

edhat-630187 (CamelContext: metar-provider-context) started in 0.000 seconds - Lukas On 2 August 2017 at 11:15, Burkard Stephan wrote: > Just a quick guess to try: have you tried to replace the "to(output)" with > "to("mock:outputFromFormatter")"? > > Ch

AW: AdviceWith in test not followed

Just a quick guess to try: have you tried to replace the "to(output)" with "to("mock:outputFromFormatter")"? Cheers Stephan -Ursprüngliche Nachricht- Von: Lukas Winkler [mailto:winklerlu...@gmail.com] Gesendet: Mittwoch, 2. August 2017 11:10 An: users@camel.apache.org Betreff: AdviceWi

AW: Deaf MockEndpoints when using Spring @DirtiesContext

he.org Betreff: Re: Deaf MockEndpoints when using Spring @DirtiesContext Search a bit more on these user forums I think some people have discussed this before, also they may got a workaround or it works in a newer release. 2.17.x is EOL. On Fri, Jun 9, 2017 at 1:53 PM, Burkard Stephan wrote: &

AW: Mocks receive no messages in Camel-SpringBoot test

t().setBody(COUNTER); } }); mockEnrich.expectedMessageCount(1); mockOut.expectedMessageCount(1); mockOut.expectedBodyReceived().constant(Prefix + (COUNTER)); camelContext.start(); template.sendBody("direct:in", 1); mockOut.assertIsSatisfied(); The AdviceWith is very powerfu

AW: Extract xml attribute value and set to request header

Hi In Java DSL you can do it like this: .setHeader("myHeader").xpath("/xpath/to/needed/element", String.class) XPath in Camel: http://camel.apache.org/xpath.html Set Message-Header example: http://camel.apache.org/constant.html Regards Stephan -Ursprüngliche Nachricht- Von: Amiya Sa

AW: Difference between WireTap and to

Hi difference between to and wiretap: Wiretap uses a dedicated thread pool to process the messages. So you have to be careful about transaction boundaries. Regards Stephan -Ursprüngliche Nachricht- Von: Caranthir [mailto:candelor...@gmail.com] Gesendet: Dienstag, 30. Mai 2017 13:23

AW: Camel ActiveMQ JMS Calls using SSL

Hi This is actually not a Camel thing, but a configuration issue of your AMQ connection. You have to configure an ActiveMQSslConnectionFactory (see below) and change the Broker-URL to ssl://broker:port instead of tcp://broker:port. If you do 2-Way-SSL you need to provide Keystore-Properties, i

AW: Processing very large files with Camel

Hi I read XML files in sizes up to about 400 MB with the following route - it uses file AND streaming component. Since it is XML the splitting is done based on a specific XML element. The chunks are then sent to a JMS queue. Before sending it to the queue you can of course do transformations

AW: Charset on file poller endpoint

s Hex: " + Hex.encodeHexString(firstThreeBytes)); ... } The log output for a UTF-16LE file is "fffe3c". This is the correct BOM (FFFE) and the first byte of the first character "<". Stephan -Ursprüngliche Nachricht- Von: Burkard Stephan Gesendet: Donners

AW: Charset on file poller endpoint

ry to read it and determine the encoding and if it has a BOM character. Finally do your conversion and put the body back to the exchange. from(file:/myDir) .to(DetermineEncoding.class, "determineEncoding") .to(activemq:queue:myQueue) On Thu, May 4, 2017 at 12:01 PM, Burkard Stephan [via C

Charset on file poller endpoint

Hi Camel users I read files with a Camel file poller and they can have different encodings (UTF-8 with or without BOM, UTF-16). Therefore I would like to determine the given encoding and convert the message body to UTF-8 without BOM for the further processing. How can I do this and what is exa

Extensible Camel routes

Hi Camel users Let's say I have this generic file to JMS route I would like to put in a library. from(directory?options...) .routeId("basicFileToJmsRoute") .log(LoggingLevel.INFO, "[FILEREADER], file: ${in.header.CamelFileName}") .to(queueEndpointUri); Then I would like to build multi

Route and route test in Spring Boot application

Hi We are moving our Camel/ActiveMQ services from Karaf bundles with Spring 3 and XML-Config to Spring-Boot with Spring 4 and Java -Config. I have built a very small prototype of such a Spring Boot application with a Camel route and the corresponding route test. I would like to know if this i