Questions tagged [apache-camel]
Apache Camel is an open source integration framework that focuses on quick and easy integration of systems consuming or producing data.
11,058
questions
0
votes
0
answers
27
views
How copy an existing object to same path Amazon S3
Hi I want to copy an existing object to same path in AWS S3 and I am getting following exception
This copy request is illegal because it is trying to copy an object to itself without changing the ...
0
votes
1
answer
11
views
cvc-complex-type.3.2.2: Attribute setHeader is not allowed to appear in element headerName (Camel)
I have seen a bunch of explaination, even on this site, about the error above... but no one was sufficiently clear about this two points:
Why appears this error?
How can I correct it exactly? What ...
0
votes
1
answer
15
views
CamelContextAware has been compiled by a more recent version of the Java Runtime
I have this error
org/apache/camel/CamelContextAware has been compiled by a more recent
version of the Java Runtime (class file version 55.0), this version of
the Java Runtime only recognizes class ...
-2
votes
1
answer
26
views
Apache camel sftp file producer [closed]
I am new to Apache Camel and I have a requirement where I need to populate a HashMap and convert it into .json file which then needs to be written to sftp server. I want to use Apache camel to achieve ...
0
votes
0
answers
19
views
Camel Java DSL .log output messages getting logged with JBoss EAP7 root logger
JBoss EAP7 + JDK11 + Camel 2.25.4
Camel Java DSL
.log(LoggingLevel.INFO, com.xxx.xxx.xxx.camel.route.XXXRoute.class.getName(), "Total items updated: 0")
gets logged as:
2022-05-18 13:45:00,...
0
votes
1
answer
31
views
Camel 2.25.4 runtime error when deployed to JBoss EAP 7
The following runtime error happens with Java 8 projects earlier deployed on JBoss EAP 6 + JDK 1.8 + Camel 2.18.4 are migrated to JBoss EAP 7.4 + JDK 11 + Camel 2.25.4:
java.lang.LinkageError: loader ...
1
vote
1
answer
27
views
Camel set body to object with header expression
Is it possible to set a response body to an object and pass in a camel header property. I can achieve this in a processor but I'd rather do it in line of the route.
.setBody(constant(
new Foo()...
0
votes
0
answers
27
views
Retrieve clob data using apache camel
I am polling clob column using apache camel as below.
<route>
<from uri="timer://timer1?period=2m" />
<setBody>
<simple>
...
0
votes
1
answer
22
views
How to pass parameter to a namedQuery from a camel route?
I have an application running camel on spring-boot.
I want to pass a parameter retriesAllowed to a namedQuery from a camel route.
namedQuery:
@NamedQuery(name = "findFailedMessages", query = ...
1
vote
1
answer
23
views
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.txt
otherfile2.txt
I need to find latest ...
0
votes
0
answers
30
views
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 3.x (due to java 11 compatibility).
We ...
0
votes
0
answers
20
views
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 populated before routing.
But xpath won't ...
2
votes
1
answer
28
views
Apache Camel: compound conditions by using the predicateBuilder and access them from the when() function
I am trying to compound conditions with the PredicateBuilder and saving it to the header to access the predicate from the when() function. At the beginning I set the body to Hello World. Also the ...
0
votes
1
answer
15
views
Is Camel doWhile a real do-while?
I read in the Camel documentation that we can use looping with a doWhile construct.
But it is not clear to me: does the Camel's doWhile behaves like a classic do-while (executing at least once without ...
2
votes
1
answer
45
views
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 like:
if(body != null &&...
0
votes
0
answers
17
views
Apache camel pollEnrich strangeness
I am having a number of type conversion issues using the Java DSL with Camel 3.14.3. For a simple example I have a route that uses a direct endpoint to trigger a pollEnrich for a file endpoint.
...
-2
votes
1
answer
28
views
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}{345}{4
5
6
}ETXSOH{111}{222}{3
3
3
}...
1
vote
1
answer
28
views
Calling Apache Camel route from a REST controller
I have a job that looks like this:
@Named
public class MyCamelRouteBuilder extends RouteBuilder {
private static final String JOB_NAME = "abc";
private static final String ...
0
votes
1
answer
16
views
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 RouteBuilder {
@Override
public ...
0
votes
0
answers
7
views
Apache Camel graphql custom header request
I have tried to make GraphQL request with Apache Camel graphql component. Is there any way to setup custom header in qraphql POST request?
I tried to put in header key/value param, but there is no ...
0
votes
1
answer
21
views
How to prevent kafka to mqtt Apache Camel route from failures?
I have a system that distributes Kafka stream data to MQTT topics. The Apache Camel routes looks like that:
<?xml version="1.0" encoding="UTF-8"?>
<routes xmlns="http:...
0
votes
1
answer
42
views
I could not run my program due to error caused by the camel context, what should I do to resolve this?
So what I'm trying to do here is to create a zoom meeting through camel apache. I keep getting the error whenever I run the program and the line causing the error is when I start the camel context c....
0
votes
1
answer
41
views
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 appreciated. Based on some example code, I ...
0
votes
0
answers
18
views
How to capture SNMP traps in a spring boot application
Senario:
I am working on a web application using spring boot which captures the SNMP traps generated by a server.
Help wanted:
Suggest to me the correct technology to implement this scenario i.e. ...
-1
votes
0
answers
34
views
I'm not able to make the sftp connection with apache camel [closed]
I'm not able to make the sftp connection with apache camel, I have the error below.
I've already updated the jsch lib to the latest version, because I had another error before that.
I'm testing with a ...
1
vote
0
answers
27
views
Apache camel error: Failed to extract body due to: javax.jms.JMSException: Forbidden class java.util.ArrayList
I try to use the next case with Apache Camel framework:
Get the CSV file
Split data and send it to the queue
Recieve data from the queue
Csv file:
"id","from","to",&...
-1
votes
0
answers
26
views
Difference between Camel Scheduler and Camel Timer
What is the difference between the Scheduler component and the Timer component of Apache Camel, specifically in the below code example
Scheduler
from("scheduler://foo?delay=60000").to("...
0
votes
1
answer
38
views
Apache Camel transform JSON to POJO
I'm trying to transform a simple JSON-file to a POJO in Apache Camel, but I cannot get it to work.
Routes.java
package org.acme.bindy.ftp;
import org.apache.camel.Exchange;
import org.apache.camel....
0
votes
0
answers
22
views
Can you listen for SpringCamelContext status?
Using EventNotifierSupport, I can listen for CamelContextStartedEvent. However, I need to add one more root to the context, after all the other routes have already been initialized. Currently, the ...
0
votes
0
answers
10
views
Clustered Apache Camel to run Jira routes
Background: We have written a Spring Boot Apache Camel based ingestion service which runs Camel routes that ingest data from shared directory (Excel files) and Jira (API calls). Jira based routes are ...
0
votes
0
answers
23
views
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). Now the message is getting send to server ...
0
votes
0
answers
37
views
Making REST calls in parallel in Apache Camel
I am using Apache Camel Java DSL in a Spring Boot project. In the Camel route, I am calling two rest services sequentially, combining their outputs and sending to another application from the Camel ...
1
vote
1
answer
36
views
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, but I get Access Denied when trying to ...
0
votes
0
answers
20
views
using useSystemProperties for apache camel http component
According to apache camel document
useSystemProperties could be used as query param for http component like below shown
https://URL ?useSystemProperties=true
But I want to use do it via API(method) ...
1
vote
1
answer
25
views
Call groovy script dynamically in Apache Camel using doTry-doCatch
I'm building a route which calls a groovy script whose path is dynamically computed and, if the script can't be found, defaults to a generic, static script:
.doTry()
.toD("language://groovy:...
0
votes
0
answers
16
views
Camel Salesforce Kafka Source Connector does not start
I am trying to run the Camel Salesforce Kafka Source Connector version 1.0.x (LTS) and following the documentation as described on https://camel.apache.org/camel-kafka-connector/1.0.x/reference/...
0
votes
1
answer
29
views
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: reader can not be null
at com.sun.xml....
0
votes
1
answer
23
views
How to create an interceptor for Apache Camel Route in Spring boot application
I have a simple route defined and for this route I want to define an outgoing interceptor so that on any request done, I would invoke an enricher that sets specific header.
from("direct:...
0
votes
1
answer
61
views
Unable to create camel salesforce endpoint
I am trying to connect to salesforce using Apache Camel salesforce component.
Here is a very simple route I am trying to start:
@Override
public void configure() throws Exception {
from("...
1
vote
0
answers
29
views
Apache-Camel - Create Zip file from stream and send to SMTP server
I am looking for sample code references to email zip file (from stream) to SMTP server in camel Java.
Here is what I tried and this code gives me : org.apache.camel.NoTypeConversionAvailableException: ...
0
votes
1
answer
42
views
Apache Camel: pollEnrich does not call dynamic URI
I have a route to poll the email from the server. In the FunctionRoute I am trying to pass the subject of the email I want to fetch by the IMAP protocol using pollEnrich method in the ...
0
votes
1
answer
26
views
How to mock a response to some expected object using CamelTestSupport?
There's a DTO created on a builder method (assume it has only a "name" attribute with some random value) and I want to check if the returned object has the same value, but the response is ...
0
votes
0
answers
12
views
Camel MessageID are different route transformation flow
In my camel application, I am trying to send a message from the source AMQ Queue (INLET) doing some TRANSFORMATION(XMLTO JSON) to Target AMQ Queue (OUTLET) The message is successfully transferred from ...
0
votes
0
answers
26
views
Apache Camel delete file when ftp/sftp disconnect
I use camel to read files by ftp or sftp but when these are too large the connection stops and I can not delete the file, is there a way to avoid this problem ?
This is my route:
var ftpUri = "$...
0
votes
1
answer
28
views
How do I set custom tracer in ModelCamelContext?
I am implementing simple camel application using camel 3.14.0.
I start using modelcamelcontext.
But there is below exception during setting custom tracer.
2022-04-29 17:04:18.474 INFO 10264 --- [ ...
0
votes
1
answer
24
views
How to test camel route that only set properties
I have a route builder that depending on the content of a message sets specific properties. It doesn't send it to other endpoints so I cannot mock them and check what they got.
I can produce a message ...
0
votes
2
answers
59
views
How to call multiple routes sequentially without messing with body
I have something like the following:
.from("direct:start")
.to("direct:a")
.to("direct:b")
.to("direct:c");
The issue I have is direct:a modifies ...
0
votes
1
answer
47
views
org.apache.camel.NoSuchBeanException for error handler mapped to route
I have the following route definitions file (linehaul-routes.xml):
<routes xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://camel.apache.org/schema/spring&...
0
votes
1
answer
23
views
Reconsume message from ActiveMQ
When the message is consumed and there is an issue with the processing of the message and it's not saved in the datasource. Since the message is consumed it's not present in ActiveMQ broker and ...
0
votes
0
answers
51
views
Unable to override uri-endpoint-override override-endpoint options for STS
Our goal is to no longer access AWS endpoints via a custom proxy but to access them via VPC endpoints from AWS. To make this work in our secured network we use our own VPC endpoints which we configure ...