Category "apache-camel"

How get specific file from directory using apache camel in java?

I have an scenario, a directory contains various file named pattern filehhmm like: hh=hours mm=minutes dir: file1200.txt file1210.txt file1220.txt otherfile1.tx

Uploading to an S3 bucket with Apache Camel how do I enable server side encryption with S3 managed keys?

I'm using Apache Camel with the aws2-s3 module to access an S3 bucket. I'm using endpoint-dsl to program my routes. I can connect to and read from the bucket, b

replacement for camel cxfbean

we are currently struggling with updating our legacy service (non spring, jee + deltaspike, weld) and it's dependencies. We try to upgrade from camel 2.16.2 to

Camel SFTP with Quartz scheduler: prevent concurrent execution, reject task if busy

Camel 3.11 Spring Boot 2.5 Java 11 I have a dynamic Camel routes that fetches files from an SFTP server. There is one route per SFTP user. The routes are schedu

Camel POJO to PAYLOAD

I'm handling a web service with camel xml ?dataFormat=POJO on the from But a front end dev is shoving some data in a field now, and I need to check if it's popu

JAXB unmarshalling - reader cannot be null

I want to retrieve some data from JMS, filter them and send them to REST server. When I unmarshal those data I get an error: java.lang.IllegalArgumentException

Run one Apache Camel route at a time

My product has an ingestion service written using Java which runs Apache Camel routes. There are multiple ingestion service instances running on different VMs.

How to count duplicated messages of Idempotent Consumer with a metric?

I have an Apache Camel application with an Idempotent Consumer. I need a metric with the total number of duplicated messages. How could I implement such a metri

Convert Oracle BPEL forEach to Apache Camel

In a migration from Oracle BPEL to Apache Camel, which particular considerations should I have for migrating forEach (Oracle) to loop (Camel)? this one is the B

How to stop camel doWhile loop

We have a independent bundle creating factory parts based on a few header variables [direct-vm:createPartService]. My application needs loop through a list of

Camel file component throughput when readLock=changed

I'm using Apache Camel to transfer files from an input directory to a messagebroker. The files are written via SFTP. To avoid consuming incomplete files that ar

No consumers available on endpoint: Endpoint[direct://LookUpRoute]

I'm new to Apache Camel. I'm trying to send an exchange from a java method to a route but it gives me "Caused by: org.apache.camel.component.direct.DirectConsum

No consumers available on endpoint: Endpoint[direct://LookUpRoute]

I'm new to Apache Camel. I'm trying to send an exchange from a java method to a route but it gives me "Caused by: org.apache.camel.component.direct.DirectConsum

Apache Camel: using compound conditions in when()

I am using Apache Camel DSL route and want to check if the body is not null and body does not contains substring like authenticate failed. In java something lik

Apache Camel Split by start and end characters SOH and ETX

I have an spring boot application which have routes.xml being loaded on startup On the routes.xml, i have a MQ queue source that contains sample message SOH{123

Apache Camel: MethodNotFoundException, Failed to invoke method on null due to: MethodNotFoundException

I try following a video tutorial for Apache Camel education and trying aggregate queue objects in a next way: @Component public class AggregationRoute extends R

Apache camel route is not identified

I have a spring boot application to which I am adding a camel route. The class where the route is defined extends FatJarRouter and is annotated with @Component.

Can't use onCompletion route scope with transacted routes

I didn't manage to customize transacted route with rollback/commit post-processing. Any help on how to write this kind of transacted route will be really appre

Apache camel setHeader in spring xml dsl

I just have assigned to apache camel project in the company where I work. The project is with spring xml dsl. I'm curious about strange behaviour of the attribu

How to browse messages from a queue using Apache Camel?

I need to browse messages from an active mq using Camel route without consuming the messages. The messages in the JMS queue are to be read(only browsed and not