Camel processes only the first 150 rows in CSV

2017-05-17 Thread Ambika Das
Hi All, I am developing a aggregator application which is supposed to consume a CSV and generate the message. I have developed it as a Spring boot application. The problem is when I transfer a file it takes only the first 150 record and processes. The file is still there in the folder. If I re

Re: Global restConfiguration

2017-05-17 Thread Tomohisa Igarashi
Hi, I haven't tried it but from the code it seems to be applied at component level unless you override it in each rest definition. https://github.com/apache/camel/blob/master/camel-core/src/main/java/org/apache/camel/model/rest/RestBindingDefinition.java#L86 Thanks, Tomo On 05/18/2017 11:55 A

Global restConfiguration

2017-05-17 Thread DariusX
I have something like this inside one of my Camel RouteBuilder classes: restConfiguration().component("servlet").port(8080)..bindingMode(RestBindingMode.xml) Does this apply to the component? In which case, it does not need to be repeated in each Camel RouteBuilder, but must only be specified in

Re: 2.19.0 Rest Producer DSL http4 support for PUT workaround

2017-05-17 Thread owain
Done. https://issues.apache.org/jira/browse/CAMEL-11293 -- View this message in context: http://camel.465427.n5.nabble.com/2-19-0-Rest-Producer-DSL-http4-support-for-PUT-workaround-tp5799706p5799725.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Processing very large files with Camel

2017-05-17 Thread Rajith Muditha Attapattu
Thank you Stephan for the quick answer! On Wed, May 17, 2017 at 11:39 AM, Burkard Stephan wrote: > Hi > > I read XML files in sizes up to about 400 MB with the following route - it > uses file AND streaming component. > > Since it is XML the splitting is done based on a specific XML element. The

AW: Processing very large files with Camel

2017-05-17 Thread Burkard Stephan
Hi I read XML files in sizes up to about 400 MB with the following route - it uses file AND streaming component. Since it is XML the splitting is done based on a specific XML element. The chunks are then sent to a JMS queue. Before sending it to the queue you can of course do transformations

Processing very large files with Camel

2017-05-17 Thread Rajith Muditha Attapattu
I have a very large flat file, say 50-100 GBs (ex daily transactions). I'm looking at the possibility of using camel to process the flat file and update a database Camel file and stream components come into place. My gut reaction is to have a route that simply read 500MB to 1GB worth of data and

Re: 2.19.0 Rest Producer DSL http4 support for PUT workaround

2017-05-17 Thread Claus Ibsen
Hi Ah yeah the put in the rest url should take precedence. Can you log a JIRA ticket. On Wed, May 17, 2017 at 2:07 PM, owain wrote: > I have swapped out a route previously using http4 directly for the more > succinct newly released producer DSL. > > What was working as: > > from("direct:get

Re: Redelivery of message in case of exception inside aggregator

2017-05-17 Thread Claus Ibsen
I suggest to use a profiler to see what is going on in your JVM. You may need to tweak restlet accordingly to your needs. You can set limits on thread pools and whatnot. And maybe also the load on the JVM if you have a lot of messages queued up etc. Camel has little overhead, so its often other

Re: LDAP search

2017-05-17 Thread Ajay
Hi Zoran, Thanks for your help I resolved my problem by changing my endpoint URI as following: -- View this message in context: http://camel.465427.n5.nabble.com/LDAP-search-tp5799687p5799705.html Sent from the Camel - Users mailing list archive at Nabble.com.

2.19.0 Rest Producer DSL http4 support for PUT workaround

2017-05-17 Thread owain
I have swapped out a route previously using http4 directly for the more succinct newly released producer DSL. What was working as: from("direct:getCounter") .routeId("i4ip-Get-Counter") .setHeader("CamelHttpMethod", constant("PUT")) .to("http4://{{counter.service.host}}:{{co

Re: Redelivery of message in case of exception inside aggregator

2017-05-17 Thread codentravel
Thanks for the reply. I did exactly the same yesterday.. It seem to be working fine.. Do you have any suggestion bring the CPU down ? Currently it consumes about 70% of CPU (beaglebone with 1gb of RAM) for 15 messages/second. Is it normal for Camel to consume so much of CPU ? -- View this m

Re: Redelivery of message in case of exception inside aggregator

2017-05-17 Thread Claus Ibsen
It can be because the message body from REST is streaming based http://camel.apache.org/why-is-my-message-body-empty.html And also you send to seda and don't wait, hence the REST consumer may close the stream before the aggregator is aggregating the newExchange. So you should likely convert the m

Re: LoginService is cleared when second rest dsl service is added

2017-05-17 Thread Claus Ibsen
Can you try with a newer Camel release, and the upcoming 2.17.7 release On Tue, May 16, 2017 at 5:59 PM, adie wrote: > Hello, > I have a strange behavior with Camel 2.17 and camel-jetty9 (2.17.0 > referencing jetty 9.2.15.v20160210). I am currently having following > service: > > > > We have a

Re: Camel-SQL 2.18.2 problem with MongoDbBasicConverters

2017-05-17 Thread antopet
Hi, Yes it is something when I run the code in wildfly (in 4.6.0), when I run it in standalone mode I don't get the problem. I try to connect a PostgresDb not a mongoDB. And the problem is (from the log): Is the line,in DefaultSqlPrepareStatmentStrategy.java: 186: Map bodyMap = safeMap(exchange

Re: Re-intilaizing Camel route?

2017-05-17 Thread Johannes F. Knauf
On 17.05.2017 08:04, Prasad k wrote: > > I need camel route, which is being initialized using configurations stored > in database, to re-initialize on every change in database configuration at > run time(without Re-starting server)? You might also want to have a look at using Camel routes package

Re: Servlet Session Handling

2017-05-17 Thread Claus Ibsen
Hi Yeah you can get that via HttpMessage which is the message implementation when using camel-servlet. HttpMessage hm = exchange.getIn(HttpMessage.class); HttpSession = hm.getRequest().getSession(); On Wed, May 17, 2017 at 11:55 AM, raja wrote: > hi all, > Is there any way to get/set session

Servlet Session Handling

2017-05-17 Thread raja
hi all, Is there any way to get/set session attribute(Session Handling) in camel Servlet? -- View this message in context: http://camel.465427.n5.nabble.com/Servlet-Session-Handling-tp5799692.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: LDAP search

2017-05-17 Thread Zoran Regvart
Hi Ajay, if you want to have dynamic values in your endpoint URI's you need to use `toD`[1] instead of `to`, zoran [1] https://camel.apache.org/message-endpoint.html#MessageEndpoint-DynamicTo On Wed, May 17, 2017 at 11:08 AM, Ajay wrote: > Hello, I`m newbie in Camel and I`m trying to create an

LDAP search

2017-05-17 Thread Ajay
Hello, I`m newbie in Camel and I`m trying to create an LDAP connection, *Unfortunately* I got this exception that [05/17/17 12:59:13:350] DefaultErrorHandle E [SAPCRequest ] [570763373-4:19:1:1:1]- Failed delivery for (MessageId: ID:p