Cannot locate BeanDefinitionParser for element [threadPoolProfile]

2015-04-29 Thread apara
I added this definition to my spring wiring: ?xml version=1.0 encoding=UTF-8? beans xmlns=http://www.springframework.org/schema/beans; xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance; xmlns:camel=http://camel.apache.org/schema/spring; xsi:schemaLocation=

Passing header between routes

2015-04-29 Thread Vanshul . Chawla
Hello, Is there a way we can pass headers between routes. My camelcontext has 3 routes Route 1 Timer triggered which populates values in a cache(StartupOrder for route as 1) Route2 Fetches from cache and populates a header(startup 2) Route3 This route picks message from queue and uses the

Re: GenericFileMessage creates body from file multiples times

2015-04-29 Thread A.Light
In case the answers to my questions are no, considering the serious issue of having a supposedly empty body suddenly filled with the whole file, I would then consider the extreme solution of giving up lazy reading (or at least having it optional, with clear explanations of the consecuencies).

RE: Passing header between routes

2015-04-29 Thread mukundha
Try like this, ${property.XXX}. -- View this message in context: http://camel.465427.n5.nabble.com/Passing-header-between-routes-tp5766477p5766493.html Sent from the Camel - Users mailing list archive at Nabble.com.

RE: Passing header between routes

2015-04-29 Thread Vanshul . Chawla
My camel context is like this ?xml version=1.0 encoding=UTF-8? blueprint xmlns=http://www.osgi.org/xmlns/blueprint/v1.0.0; xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance; xmlns:camel=http://camel.apache.org/schema/blueprint;

Re: Cannot locate BeanDefinitionParser for element [threadPoolProfile]

2015-04-29 Thread Claus Ibsen
Hi Put it inside camelContext On Wed, Apr 29, 2015 at 7:17 AM, apara ap...@standardset.com wrote: I added this definition to my spring wiring: ?xml version=1.0 encoding=UTF-8? beans xmlns=http://www.springframework.org/schema/beans;

Re: GenericFileMessage creates body from file multiples times

2015-04-29 Thread Claus Ibsen
Returning null from a bean is considered as a noop operation - eg dont change the message. If you want to set the message to null then use a message translator eip such as transform transformsimple${null}/simple/transform On Wed, Apr 29, 2015 at 11:15 AM, A.Light

Re: webservice proxy using spring

2015-04-29 Thread jainmcs03
Thanks Francois. -- View this message in context: http://camel.465427.n5.nabble.com/webservice-proxy-using-spring-tp5766439p5766471.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: webservice proxy using spring

2015-04-29 Thread jainmcs03
Francois, In this way i got a error on my console. Attaching logs. Regards Jayendran EclipdeIDE_logs.EclipdeIDE_logs http://camel.465427.n5.nabble.com/file/n5766472/EclipdeIDE_logs.EclipdeIDE_logs -- View this message in context:

Re: webservice proxy using spring

2015-04-29 Thread jainmcs03
Francois, I managed to make it works using the option below,thanks, route streamCache=true Regards Jayendran -- View this message in context: http://camel.465427.n5.nabble.com/webservice-proxy-using-spring-tp5766439p5766495.html Sent from the Camel - Users mailing list archive at

RE: Passing header between routes

2015-04-29 Thread mukundha
Hi Chawla, In the below code from route1 to route2 the same exchange will flow. But when you see the route3 which is not having any link with this two routes, so it will have different exchange where you cannot find the property. The property is lost in the second route as there is no routes

Re: Passing header between routes

2015-04-29 Thread mukundha
Hi Chawla, Use the property instead of header, as the header will be different from exchange to exchange. please find the syntax below, setProperty propertyName=name simplevalue/simple /setProperty Thanks, Mukundha Reddy -- View this message in context:

Re: GenericFileMessage creates body from file multiples times

2015-04-29 Thread A.Light
Hi Willem, thanks for your reply. The more I think about this, the more I get convinced that this isn't right. Whatever the case is, the file should be read only once. I cannot find a scenario where reading the file more than once is different than exploiting a loose side effect. Maybe it's

CSV and SQL Component for Batch Processing

2015-04-29 Thread imranrazakhan
Hi, I am doing batch insertion into db from CSV file like from(file:mycsv) .unmarshal().csv() .to(sql:insert into mytable (value1, value2) Values (#, #)?batch=true) .end(); It works fine if CSV columns and Table columns are same, but my CSV

RE: Passing header between routes

2015-04-29 Thread Vanshul . Chawla
How to access it back in other route? I tried that earlier and then accessed it via ${properties.XXX} but didn't work. Thanks and Regards, Vanshul Chawla -Original Message- From: mukundha [mailto:v.re...@wipro.com] Sent: Wednesday, April 29, 2015 3:49 PM To: users@camel.apache.org

Re: camel-jackson unmarshalling question

2015-04-29 Thread David Karlsen
It can probably be done by adding jackson annotations: http://wiki.fasterxml.com/JacksonAnnotations Polymorphic ...: 2015-04-29 7:54 GMT+02:00 Claus Ibsen claus.ib...@gmail.com: Hi No this is not supported today. Though we could maybe add that, so you can configure this on the data

Re: camel-jackson unmarshalling question

2015-04-29 Thread Claus Ibsen
Hi No this is not supported today. Though we could maybe add that, so you can configure this on the data format. On Mon, Apr 27, 2015 at 1:05 AM, Ryan Moquin fragility...@gmail.com wrote: Hi, I had a question about unmarshalling a json object to a generic class type, such as something like,

Re: Done file not deleted

2015-04-29 Thread Claus Ibsen
Hi Its wrong assumption - the done file is also deleted per file when the done file is dynamic, eg it has {file:name in the name, such as doneFile=${file:name}.done But if the done file is a static name such as doneFile=end.txt Then its only deleted at the end of batch. On Mon, Apr 27, 2015 at

Bug in createRegistry of DefaultCamelContext?

2015-04-29 Thread Victor NOËL
Hi, I have been trying to programmatically register an object in the registry and I got the following exception: org.apache.camel.RuntimeCamelException: javax.naming.NoInitialContextException: Need to specify class name in environment or system property, or as an applet parameter, or in an

How to create case insensitive URI route with netty4-http?

2015-04-29 Thread hzariv
I am using Camel netty4-http and want to create Consumer EndPoint which is matches on case insensitive URI path. For example: camelContext.getEndpoint(netty4-http:http://0.0.0.0:8080/Shopping;); or camelContext.getEndpoint(netty4-http:http://0.0.0.0:8080/shopping;); How can I do that? --

Conditional based routing query

2015-04-29 Thread gilboy
Hi I have a route which consumes messages from a JMS Queue. The type of messages being placed on the queue are JMSObjectMessage's. There are 2 different types of objects I may be sent - a Customer or a Supplier. In the route which consumes the message I would like to do some conditional based

How to get specific context with CamelContextAware interface?

2015-04-29 Thread apara
I have multiple camel contexts in my application. How do I get a specific context with CamelContextAware interface implementation? Thanks. -AP_ -- View this message in context: http://camel.465427.n5.nabble.com/How-to-get-specific-context-with-CamelContextAware-interface-tp5766519.html Sent

Unable to setup route with limit of 30 queue size and 5 processing threads

2015-04-29 Thread apara
I am trying to build a route at runtime which limits the caller to maximum of 30 objects in a queue, with 5 concurrent processing threads. I also want the caller to get an exception when more than 30 objects attempt to be inserted into the route. Following this example:

Re: Unable to setup route with limit of 30 queue size and 5 processing threads

2015-04-29 Thread apara
I tried this variation: routeDefinition = from( routeName ) .threads() .executorServiceRef(bigPool) .inOnly( vm:single.record.processor?concurrentConsumers=5size=30 ); By adding

org.apache.camel.ExchangeTimedOutException: The OUT message was not received within: 30000 millis

2015-04-29 Thread apara
All my beans in the route implement this interface: public interface Handler { EventData handle(EventData data) throws HandlerException; } They are all exported via camel:export and the following works nicely: camel:route camel:from uri=direct://handle.event /

Re: TypeConversion Error

2015-04-29 Thread Willem Jiang
Can you try to disable the stream cache and try again? -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On April 28, 2015 at 9:23:51 PM, Scarpacci

Re: camel-jackson unmarshalling question

2015-04-29 Thread Ryan Moquin
Thanks for your response Claus! I think it would be a useful feature.. Maybe I'll try to figure it out one of these days so I can contribute it. Ryan On Wed, Apr 29, 2015, 6:15 AM Claus Ibsen claus.ib...@gmail.com wrote: Hi No this is not supported today. Though we could maybe add that,

Re: camel-jackson unmarshalling question

2015-04-29 Thread Ryan Moquin
Good point, I forgot I could probably utilize tannotations to do it for now. :) Ryan On Wed, Apr 29, 2015, 6:28 AM David Karlsen davidkarl...@gmail.com wrote: It can probably be done by adding jackson annotations: http://wiki.fasterxml.com/JacksonAnnotations Polymorphic ...: 2015-04-29

Re: Conditional based routing query

2015-04-29 Thread Claus Ibsen
Hi Yes using the content based router and then predicates that check if the message body type is what you want On Wed, Apr 29, 2015 at 6:03 PM, gilboy josephoto...@gmail.com wrote: Hi I have a route which consumes messages from a JMS Queue. The type of messages being placed on the queue are

Re: How to create case insensitive URI route with netty4-http?

2015-04-29 Thread Claus Ibsen
Can you tell more what you mean? The netty4-http component uses a case insenstive uri path matcher. On Wed, Apr 29, 2015 at 6:40 PM, hzariv hza...@ebay.com wrote: I am using Camel netty4-http and want to create Consumer EndPoint which is matches on case insensitive URI path. For example:

Re: Unable to setup route with limit of 30 queue size and 5 processing threads

2015-04-29 Thread apara
Ok, according to documentation on the bottom of this page: http://camel.apache.org/using-camelproxy.html I did the following: public interface AsyncHandler { FutureEventData asyncHandle(EventData data) throws HandlerException; } public interface SyncHandler { EventData handle(EventData

Re: Unable to setup route with limit of 30 queue size and 5 processing threads

2015-04-29 Thread apara
Ok, I just found this thread: http://camel.465427.n5.nabble.com/How-to-impl-bean-side-of-proxy-w-Future-return-td4581104.html Does not look like it's possible to use anything other than direct:// with proxy spring beans. It seems that it should just work, but apparently it does not. Kinda wish

Re: org.apache.camel.ExchangeTimedOutException: The OUT message was not received within: 30000 millis

2015-04-29 Thread apara
I spent a day trying to figure this out with no luck. I re-read the threading chapter in Camel in Action book, but could not find how to multi-thread vm:// or seda:// routes. Perhaps I need to go back to using direct:// with some threading option. I just don't know. I tried using: vm://

Re: Unable to setup route with limit of 30 queue size and 5 processing threads

2015-04-29 Thread apara
Just tried, direct-vm... does not work either. Apparently does not concurrentConsumers parameter. -- View this message in context: http://camel.465427.n5.nabble.com/Unable-to-setup-route-with-limit-of-30-queue-size-and-5-processing-threads-tp5766520p5766528.html Sent from the Camel - Users

Re: TypeConversion Error

2015-04-29 Thread Scarpacci
Hi Willem, Finally figured it out. I had to set the CachedOuptutStream.Threshold to greater than the default. camel.context.getProperties.put(CachedOutputStream.THRESHOLD, 75); It was not clear at all that this was the case because of the conversion error...thanks for all your help! S

Re: Unable to setup route with limit of 30 queue size and 5 processing threads

2015-04-29 Thread apara
I found http://camel.apache.org/toasync.html, which I was going to try to implement, however, it seems to be deprecated. Is there a replacement to convert direct:// proxy to async? -- View this message in context:

Re: GenericFileMessage creates body from file multiples times

2015-04-29 Thread A.Light
Claus, I gave it a thought but... if what you say is true, why when the body type is String then - after the bean call - the body does atually change to null? It seems to be a problem of consistency or maybe there's a bug in the noop implementation, I don't know. Anyway, I debugged the code and

Re: RecipientList thread pool problem

2015-04-29 Thread Alexander Ilyin
Hi Claus, thank you for your answer. I hadn't configured netty request timeout before I wrote my first letter. Now I've read that tasks may keep running when using RecipientList timeout and have set up netty request timeout instead of RecipientList timeout as you suggested. But the situation