81 questions
- Bountied 0
- Unanswered
- Frequent
- Score
- Trending
- Week
- Month
- Unanswered (my tags)
0
votes
1
answer
321
views
Camel Quarkus SFTP Idempotent Consumer "this.transactionTemplate is null" error
I've been developping a Quarkus app with STFP routes, in which I would like to incorporate IdempotentConsumers. The end goal is to deploy multiple instances in my cluster and achieve Distributed ...
0
votes
0
answers
540
views
not found in bean: org.apache.camel.converter.stream.InputStreamCache
Have a below script , which is throwing an error :
.log("message: ${body}")
//message: {"caListID":88186,"ciqWatchListID":706596203}
.setHeader(KafkaConstants.KEY, ...
0
votes
1
answer
665
views
How to convert a Camel body to one of its properties
I try to set up a simple Camel route, using Spring Boot.
It reads a single column from a database table and puts a message on a ActiveMQ Artemis queue for every row.
Quite simple, but I struggle to ...
0
votes
1
answer
1k
views
Camel SQL - Individual Insert to Batch
I am using Camel SQL. I am trying to gather data from Oracle and insert it into Snowflakes.
Below is the code snippet.
from(sql:select*...?dataSource=#oracleDataSource&repeatcount=1&batch=true)...
0
votes
0
answers
169
views
Getting error with sql named query when trying a batch insert
from("{{my.app.source}}")
.unmarshal()
.bindy(BindyType.Csv, EmployeeCsvRecord.class)
.split(body())
.streaming()
...
0
votes
1
answer
343
views
Set Headers in MULTICAST camel route
<route id="SUB2I0051">
<from uri="seda:SUB2-I0051MTMapper"/>
<multicast>
<to uri="file:C:/complexTest/?fileName=MT_Output.txt" />
<setHeader name="Node">
...
0
votes
1
answer
660
views
Camel Apache SQL
I am learning to use Apache Camel.
So far I've been trying to create execute a very simple SQL request which seems to not be working. I hope any of you can tell me what is wrong with the code.
Thank ...
0
votes
1
answer
515
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
1
answer
203
views
replay failure messages whenever I want in any time
#camel Hi Devs, I am currently working on a camel to transform messages from Source to Target systems, I am stuck with an issue i.e., I want redelivery my message when any exceptions occurred or due ...
0
votes
1
answer
946
views
Camel Karaf (OSGI Blueprint) SQL datasource
Hi Guys I'm having some issues with my datasource in Karaf 4.3.6 (recent upgrade) I'm hoping someone could shed some light on what I'm doing wrong here.
Before the upgrade
Karaf had the below services ...
0
votes
1
answer
1k
views
Load CSV to database using Apache Camel Spring XML (CSV to SQL components)
I want to do a simple file polling that takes in a CSV file, unmarshals it and loads specific fields into database. I guess that should be a pretty common scenario but I need to use Spring XML instead ...
0
votes
1
answer
126
views
Which Enterprise Integration pattern is used in camel
I am using Apache camel route for processing my message.In my user interface I need to show these messages and in detail page I need to show the flow of message within the route
So I planned to use ...
1
vote
0
answers
189
views
SQL Component internally resets CamelSqlUpdateCount to zero
Oddly enough, the SQL component reset the CamelSqlUpdateCount header value to zero when there is a 'SET FOREIGN_KEY_CHECKS' before a 'REPLACE SELECT'.
I ran in debug mode with a watcher on the header ...
0
votes
0
answers
379
views
Camel-sql header CamelSqlRowCount is not overriden for multiple queries
I use a sql endpoint to run a query from camel.
But when i call a second the CamelSqlRowCount isn't changed:
@Component
public class TestSQLRowCount extends RouteBuilder {
@Override
public ...
0
votes
1
answer
448
views
Camel - catch SQL exception and try 3 times
Which exception is thrown when Camel route toF("sql:insert into ...") fails due to db connection issue?
I've try to capture like onException(CannotCreateTransactionException.class, ...