Relative Content

Tag Archive for apache-camel

Move file to failed in camel route

A camel route is used to handle multi-row csv files. The route from is configured with the query parameter moveFailed. This all basically works. But the rows are processed one by one and in case of error, it route shall not stop but shall continue. Afterwards, the file should be moved to failed if any error has occurred.

Replacement for removed newExchange() in Camel 3.16

I’m finally in the process of upgrading our old Camel 2.x stack. WireTapDefinition.newExchange(Processor processor) was removed in 3.16 and I haven’t found any examples of how to replace it. What should I replace it with in this instance?

Camel master not coordinating after Pod move

We’re using Camel’s “master” feature around a timer route, because we have two Kubernetes (k8s) Pods and we only want either one of them to run the timer. We’re using the camel-file implementation.

Add json-validator result to validated json object

I´m trying to validate an incoming json string against a json schema, but instead of throwing an exception if that validation fails, I´d like to forward the validation errors together with the validated json payload:

How to call .seek method for inner created Consumer with Camel pulsar lib

I’m using camel-pulsar library to build a pulsar client to consume data, but need to add a replay function incase of losing data. what I used to do is call seek method for pulsar consumer to determind when to start consuming data. but not sure if camel pulsar also support this?
camel pulsar version i’m using is 3.22.0

Apache Camel sending message to jms component

I’m currently sending messages to an activemq. So until the connection is established to this queue the messages gets delivered. If there is a connection lost to the active mq the messages that are supposed to be sent are lost in this phase.