Camel HTTPS - timing out

Hi, I have a requirement to download the data from a rest API. I am using https endpoint to call the rest API. The code is as listed below, when I try to access the Rest API through Postman, its working fine and downloads a file with 50 MB. Where as when I am trying to access the API through the

camel-ftp - Limitation or performance hit on Huge file transfers

Hi, I am exploring the camel-ftp component. My requirement is to ftp file which is in GB's from server on one Data-center to other Data-Center. I wanted to know if camel-ftp component poses any performance hit while transferring the file of such huge size. Thanks, Ganga -- View this message i

xalan 2.7.2 working in IntelliJ IDE and not as .jar

Hi, I am trying to transform xml using XSLT in Camel. The dependency I have is compile group: 'xalan', name: 'xalan', version: '2.7.2' I am trying to perform this step in xslt Am using this variable later in my xslt for further transformation When I run my camel routes t

How to Mock Kafka Consumer Endpoint with Spock Framework Unit Test cases

Hi, I am using Spock Framework to perform Unit Testing of Camel Routes. My first route consumes from Kafka Consumer Endpoint. I need to mock this end point and send the message to mock endpoint as part of the unit testing, below is how I have tried camelctx.getRouteDefinitions().get(0).adviceWith

Re: How to Mock Kafka Consumer Endpoint with Spock Framework Unit Test cases

Thanks Steve for your inputs. I changed the end point to seda from mock and things fell in place, the test ran fine -Ganga -- View this message in context: http://camel.465427.n5.nabble.com/How-to-Mock-Kafka-Consumer-Endpoint-with-Spock-Framework-Unit-Test-cases-tp5783856p5783952.html Sent

camel xslt parsing not working with Camel 2.17.1 - Nullpointer Exception

Hi, I have a camel route which will tranform the incomming xml to a specified format. I am using Camel xslt component for the same. Everything was working fine when I was using Camel 2.16.2. When I upgrdade to camel 2.17.1 the xml transformation stopped working with the below error, I am using ca

Read file one after other in sequence

Hi, My requirement is to split the large file into smaller files and then process one file at a time. However, the camel file component takes the lock on all the split files and starts processing. This is consuming all of the CPU and Memory usage goes high and at one point I get OutofMemoryExcept

Re: Read file one after other in sequence

Thanks for the inputsIt works as expected now... Thanks Vitalii. -- View this message in context: http://camel.465427.n5.nabble.com/Read-file-one-after-other-in-sequence-tp5786216p5786223.html Sent from the Camel - Users mailing list archive at Nabble.com.

Rest DSL with restlet Component, unable to access API when hosted on remote server

Hi,I have a camel route with Rest DSL using the restlet component, configuration as listed belowrestConfiguration().component("restlet").host("{{hostname}}").port("{{port}}") .dataFormatProperty("prettyPrint", "true"); rest("/books").consumes(MediaType.ALL.toString())

RE: Rest DSL with restlet Component, unable to access API when hosted on remote server

This is the error message that I get Could not get any response There was an error connecting to http://:8081/bnt?9780226519791,9780415762564. Why this might have happened: The server couldn't send a response: Ensure that the backend is working properly SSL connections are being blocked: Fix this

Accessing Websphere MQ using credentials

Hi, I am trying to connect to WMQ using UserName and password. As per one of the posts in the User group, I tried the below code for creating a wmq component @Bean MQQueueConnectionFactory jmsConnectionFactory() { jmsConnectionFactory = new MQQueueConnectionFactory(); try

Camel Aggregator - Partial Data written to file

Hi, I have written a piece of code that performs the below operations 1.Reads multiple files from input folder 2.applies xslt on each of the response 3.aggregates the transformed data 4.writes to a file in append mode The Problem I am facing is, when all of the translated data (from all the mult

Camel Cache - Trigger an event when the cache expires

Hi, I have a scenario where in I need to perform a set of operations when the cache expires (based on the timetolive set). As part of this operation, the cache will be populated with the new value. >From the documentation, I could not find anything specific. Is this possible and if yes, any guida

Camel File: Produce files based on size

Hi All, I am working on a use-case where the need is to create files based on size. To elaborate further, the file component should switch to create a new file every-time, the file that is being created exceeds a particular size of say 2GB. So, if I am in the process of writing into a file, and

File readlock on multiple files in a directory

Hi, I have a scenario where I need to sftp files from a directory to which files are being written by another route. I am using file readlock=changed on that directory. However, the readlock is taken on one file and not all the files. Hence, when the file component gets the readlock on any one of

Re: Camel Aggregator - Completion based on CamelSplitComplete

The CamelSplitComplete is at each exchange level that gets split. In case the below block is aggregating only a specific set of filtered data, then the exchanges that are getting into this block may not be the last exchange from the bigger set of exchanges and hence the block posted will never get

How to identify the last record that is getting processed?

Hi, I am trying to process a 10GB file (fixed width file) by performing the below steps 1. Split the file per record based on the newline

How to identify the last record that is getting processed?

Hi, I am trying to process a 10GB file (fixed width file) by performing the below steps 1. Split the file per record based on the newline

Camel: Processing Large fixed width files (no header)

Hi, I have a requirement to read a file (fixed width without headers), filter rejects and then append headers, zip it and send it to the downstream. The output file should have headers added to it. The file size that I will need to deal with is in GB's more than 10GB. What is the best strategy t

Camel Aggregator: Using up the complete heap

Hi, I have a camel route which will split the file based on the newline charterer and writes the data into 3 different files based on some business logic. The file is 135MB in size. While running the route, the observation is the initial processing is pretty good however as the records get proc

Camel Routes: Identify end of Processing in a Route

Hi, I am new to camel. I understand that Camel routes once started continue to be active and in running status unless its manually stopped. I have a requirement where the route should automatically stop after the processing of all the records are complete. Is there a way we can programitically

Re: Camel Spring boots

use the following archetype while creating the project GroupId=org.apache.camel.archetypes Artifactid=camel-archetype-spring-boot version=2.16.1 This will create a Spring Boot Template to run the camel routes. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Spring-boo

Camel Spring Boot - Adding JmsComponent for WMQ to Camel Context

Hi, I am exploring Spring Boot to write the camel routes...I started off by creating a Maven Project using the camel-archetype-spring-boot. The project contained 2 classes, 1. a class that extends from fatjarrouter, which houses the camel routes 2. a class by name WarInitializer which extends Fat

Re: Camel Spring Boot - Adding JmsComponent for WMQ to Camel Context

I found the answer I had to create a method that returned the jmscomponent and annotate it with @Bean. @Bean annotation is a synonym for the in camel-context.xml The name of the method is the bean name, which I used in my routes to communicate with the queues. listed as below, this will reg

Re: Camel Spring Boot - Adding JmsComponent for WMQ to Camel Context

thanks for the response.Posted my finding just before I saw your response. @Bean worked for me... Thanks, Ganga -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Spring-Boot-Adding-JmsComponent-for-WMQ-to-Camel-Context-tp5777593p5777597.html Sent from the Camel -

Re: Camel Spring Boot - Adding JmsComponent for WMQ to Camel Context

suream new to Spring annotations, will explore further... Thanks for the insight... Thanks, Ganga -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Spring-Boot-Adding-JmsComponent-for-WMQ-to-Camel-Context-tp5777593p5777627.html Sent from the Camel - Users mailing lis

Re: Caching POJOs (no serializable and no InputStream)

Hi, Was there a patch implemented for this issue. I also have a case where I need to add Pojo Objects into Cache and am not able to do so unless I convert the Pojo to a String If no fix was implemented, is there a work around to achieve this? Appreciate response. -- View this message in conte

Re: Caching POJOs (no serializable and no InputStream)

Hi, By having the pojo implement Serializable, I was successfully able to add pojo's into cache and retrieve them back without any type conversion. -Ganga -- View this message in context: http://camel.465427.n5.nabble.com/Caching-POJOs-no-serializable-and-no-InputStream-tp5738138p5778543.html