Category "apache-camel"

How to send response back from server to client using Apache camel netty , spring boot

I have two modules as client and server. I am currently sending echo messages from client to server using netty server routes from(netty:tcp://0.0.0.0:21005). N

Listing AWS S3 bucket content from Springboot With Apache Camel

I have a sprintboot project running v2.5.4 which works fine. I have access to S3 and im able to list the content of a bucket i have created. So i wanted to expe

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