Re: Stop polling the input folder after the scheduled route is completed

2017-02-27 Thread Amruta Jawlekar
I was able to stop the route finally. What I did was - 1. set sendEmptyMessageWhenIdle=true in the file component. So when all files from input folder are read and moved to backup folder, it sends empty message. 2. On empty body, I am calling a processor. 3. And in processor, I am again checking

Re: Stop polling the input folder after the scheduled route is completed

2017-02-27 Thread Amruta Jawlekar
Hi souciance, My route code : ${body} != null && ${file:ext} == 'dcn'

Re: Camel File: Produce files based on size

2017-02-27 Thread Tomohisa Igarashi
Hi, I haven't tried but using splitter with streaming=true would help that kind of usecase. http://camel.apache.org/splitter.html Thanks, Tomo On 02/27/2017 10:10 PM, ganga_camel wrote: Hi All, I am working on a use-case where the need is to create files based on size. To elaborate further,

Re: how to handle large volume of data

2017-02-27 Thread Tomohisa Igarashi
Hi, I would try camel-http4 and save it into a file. http://camel.apache.org/http4.html Thanks, Tomo On 02/27/2017 07:19 PM, Gunjara wrote: Hi , can any one help me on this , I'm invoking a rest endpoint and as a response i'm getting large amount of data . Is there any solution for that . Reg

Re: Consuming data from external REST service

2017-02-27 Thread rkmohapatra
Thank you Ravi for the tips. I did this based on your tips. - Added camel-http4-2.18.2.jar to my application - Added following libraries additionallay as I was getting classnotfoundexception errors. httpcore-4.3.3.jar httpclient-4.3.3.jar commons-logging-1.2.jar commons-httpclient-3.1.jar Do we n

Re: Consuming data from external REST service

2017-02-27 Thread Ravindra Godbole
You can try something like this. Include json specific jars as applicable for the ObjectMapper. from("direct:getRestFromExternalService") .to("http4://www.externalRestServiceUri"") .process(new Processor() { public void process(Exchange exchange) throws Exception

Camel File: Produce files based on size

2017-02-27 Thread ganga_camel
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

Re: Stop polling the input folder after the scheduled route is completed

2017-02-27 Thread Claus Ibsen
You can use controlbus to stop the rout from the route, you can do that when the batch is complete = true so you know you have processed all the files from the poll. And set async=true in the controlbus in the stop On Mon, Feb 27, 2017 at 1:51 PM, Amruta Jawlekar wrote: > Hi, > > I am working on

Re: Stop polling the input folder after the scheduled route is completed

2017-02-27 Thread souciance
Did you try to stop the route after polling was done? How does your route code look like? On Mon, Feb 27, 2017 at 1:51 PM, Amruta Jawlekar [via Camel] < ml-node+s465427n5794516...@n5.nabble.com> wrote: > Hi, > > I am working on a project which polls to one input folder, processes it > and keeps t

Stop polling the input folder after the scheduled route is completed

2017-02-27 Thread Amruta Jawlekar
Hi, I am working on a project which polls to one input folder, processes it and keeps the processed files to output folder. The input files are then moved to Backup folder. Now I want to keep this on scheduler twice a day at fixed time. I did that using CronScheduledRoutePolicy. Below is the code.

Re: Consuming data from external REST service

2017-02-27 Thread rkmohapatra
Also, please note that the REST service on an external application is based on Jersey. I tried to use this code in RouteBuilder with jetty and cxfrs, but it throws exception. from("cxfrs:http://...";).process(restProcess).to("file:d:\\output\\testrest.out"); from("jetty:http://...";).process(restP

Consuming data from external REST service

2017-02-27 Thread rkmohapatra
Hi, I am a newbie to Apache Camel. I am using Apache Camel 2.18.2 and trying to build an application that needs to do this - Make a REST call to fetch data in JSON format. The REST service is external to the application where Camel is deployed. - Process the JSON data and store in a target databa

how to handle large volume of data

2017-02-27 Thread Gunjara
Hi , can any one help me on this , I'm invoking a rest endpoint and as a response i'm getting large amount of data . Is there any solution for that . Regards, Gunjara. -- View this message in context: http://camel.465427.n5.nabble.com/how-to-handle-large-volume-of-data-tp5794510.html Sent from

Re: AW: How to Parse .tsv(tab separated value) file

2017-02-27 Thread Gunjara
Thanks :) -- View this message in context: http://camel.465427.n5.nabble.com/How-to-Parse-tsv-tab-separated-value-file-tp5794268p5794500.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel-CXF in tomee

2017-02-27 Thread Romain Manni-Bucau
Yep - thanks Claus to point it out, just realized it was not tomee@ ;), just to answer the two previous points before you switch and people can be without answer later: 1. means glassfish (check the javadoc " org.hibernate.service.jta.platform.spi.JtaPlatform

Re: Camel-CXF in tomee

2017-02-27 Thread Claus Ibsen
Hi Can you ask on Apache TomEE mailing list / user forum. This problem you have is not Apache Camel specific and its better to talk to TomEE. On Mon, Feb 27, 2017 at 7:35 AM, syadav wrote: > And also is this the only solution to delete the cxf related files from tomee > lib. Because this may me

Re: Camel-CXF in tomee

2017-02-27 Thread syadav
And also is this the only solution to delete the cxf related files from tomee lib. Because this may me deployed in many servers(production servers) and I cannot delete cxf related jars from all the instances. And also I am getting the following error when I do so but application is getting started

Re: Camel-CXF in tomee

2017-02-27 Thread syadav
But the same was working in glassfish without any change in jar and persistence.xml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-CXF-in-tomee-tp5794355p5794484.html Sent from the Camel - Users mailing list archive at Nabble.com.

header changes just after process

2017-02-27 Thread zsair
I have route below. from("direct:getJson") .removeHeaders("CamelHttp*") .setHeader("Accept", constant("application/json")) .setHeader("Cache-Control", constant("no-cache")) .setHeader(Exchange.HTTP_METHOD, constant(HttpMethods