Escaping parameters in route URI

Hello All, Iam trying to use amqp component of camel. When iam trying to define route using the below mentioned URI amqp:queue:*BURL:direct://lb-push//pingqueue?routingkey="abcd"* But unfortunately camel complains that it cant set routingkey parameter on amqp component where as the routingkey para

Re: Escaping parameters in route URI

Hello, Thanks for your response.Since camel uses QPID as AMQP implementation library,iam trying to use the bindingurlformat specified in https://cwiki.apache.org/qpid/bindingurlformat.html If i can somehow escape question mark(?) in this url,everything will work in QPID *BURL:direct://lb-push//p

Dynamic Consumers

Hello All, I have a question regarding dymaic uri inside toF() DSL Given below is my route from("direct:bootstraproute") .setHeader(Exchange.HTTP_METHOD,constant(org.apache.camel.component.http4.HttpMethods.GET)) .toF("https4://myapi.com/%s.json?type=2",header("eventid"))

Extra Request Params sent in camel HTTP component(GET request)

Hello All, Iam using camel http4 component and trying to set timeout.Given below is the URL. https4://server.com/api/close.json?appid=3&httpClient.soTimeout=1&httpClient.connectionTimeout=1 It seems like the config parameters are also sent to end server.Is there any way to avoid sending t

Re: Extra Request Params sent in camel HTTP component(GET request)

Hello Iam using v2.8.2.Do I need to upgrade any further? Thanks -- View this message in context: http://camel.465427.n5.nabble.com/Extra-Request-Params-sent-in-camel-HTTP-component-GET-request-tp5042808p5042889.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Extra Request Params sent in camel HTTP component(GET request)

Hello, You are right in that this issue is not there even in 2.8.2 I tested this with both 2.8.2 and 2.8.3.It seems to work fine in both versions.I think i got confused with this line DefaultComponent DEBUG Creating endpoint uri=[http4://host.com:14500/mockserver/event/1000693144.json

NotifyBuilder issue while integration testing?

Hello Guys, Iam trying to do integration testing using NotifyBuilder support of camel. Very basic use as highlighted below = NotifyBuilder notify = new NotifyBuilder(this.camelContext).whenDone(1).create(); //send a message boolean done = notify.matches(20, TimeUnit.SECONDS); ass

Re: Dynamic Routing

Hello, As far as iam aware from this url, http://camel.apache.org/dynamic-router.html the return value from your method should be camel endpoint URI so that the dynamic router can route message to that endpoint. http://camel.apache.org/uris.html Also have a look at FAQ.Its quite good http://camel

Re: NotifyBuilder issue while integration testing?

Hello, Iam using 2.8.3 Thanks -- View this message in context: http://camel.465427.n5.nabble.com/NotifyBuilder-issue-while-integration-testing-tp5068648p5071046.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: NotifyBuilder issue while integration testing?

Many Thanks for your response. It works like a treat Thanks -- View this message in context: http://camel.465427.n5.nabble.com/NotifyBuilder-issue-while-integration-testing-tp5068648p5072197.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Possible Memory Leak when JMX is enabled

Hello Guys, Just updating this message as i experienced similar memory leak.But it was very obvious that it was because of 1)enabling JMX. so i disabled it in camelcontext 2)i was starting and stopping routes dynamically and when i used to stop,i just used to call stopRoute(). Now iam calling r

Re: ProducerCache memory leak?

No iam not.For every "to" dsl in routebuilder,sendprocessor gets invoked and it is newing up producercache instances. Thanks -- View this message in context: http://camel.465427.n5.nabble.com/ProducerCache-memory-leak-tp5108206p5108260.html Sent from the Camel - Users mailing list archive at Nab

ProducerCache memory leak?

Hello All, Iam using camel 2.8.3 and have an issue regarding ProducerCache objects not being garbage collected. I browsed through this list regarding the same with not much luck. I dynamically start and stop the route throughout my application and when i do that it seems like camel retains lot of S

Re: ProducerCache memory leak?

Hi Guys Thanks for your reply. I do stop route using API.I call context.stopRoute() and context.removeRoute() using routeid. Here is my routebuilder.To be honest i have a Suspicion on "onException" DSL.Iam not so sure.Let me know what you guys think ===

Re: ProducerCache memory leak?

I even moved the onexception clause from Global scope to Route scope,but still suffer from the same issue -- View this message in context: http://camel.465427.n5.nabble.com/ProducerCache-memory-leak-tp5108206p5110006.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: ProducerCache memory leak?

Hello, Thanks for looking into this. Regards Suman -- View this message in context: http://camel.465427.n5.nabble.com/ProducerCache-memory-leak-tp5108206p5110045.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: ProducerCache memory leak?

Currently I have disabled jmx in my app as I saw memory leaks in the past Now I came to know it's because iam adding routes on the fly Thanks -- View this message in context: http://camel.465427.n5.nabble.com/ProducerCache-memory-leak-tp5108206p5112120.html Sent from the Camel - Users mailing li

Re: ProducerCache memory leak?

Hi, Thanks for quick resolution .I will give it a go next week and post the results Thanks Suman -- View this message in context: http://camel.465427.n5.nabble.com/ProducerCache-memory-leak-tp5108206p5112516.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: ProducerCache memory leak?

Hello, I tested this with 2.8.4 branch and the memory growth of producercache is drastically reduced but hasn't gone away completely. I looked at immediate dominator in eclipse memory analyzer tool and SpringcamelContext seems to be holding producercache instances Let me know if you need more infor

Re: ProducerCache memory leak?

I counted the numbers which were created and the numbers which were removed.. I can easily see producercache for receipientlist isn't being cleared in removeService() method of DefaultCamelContext.java.I will do some more analysis and keep you posted. -- View this message in context: http://camel

Re: ProducerCache memory leak?

Not sure if I need to add routeid to onexception and stop that as well.I will give it a try -- View this message in context: http://camel.465427.n5.nabble.com/ProducerCache-memory-leak-tp5108206p5117692.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: ProducerCache memory leak?

t;); ===== Let me know what you think Thanks Suman -- View this message in context: http://camel.465427.n5.nabble.com/ProducerCache-memory-leak-tp5108206p5119302.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: ProducerCache memory leak?

Hello, Thanks for quick response. I moved the exception clause to route scope but i get the following exception while starting route.And this is because using recepientlist within that exception handling. === 2012-01-04 11:14:50,612 [ main]

Re: ProducerCache memory leak?

Thanks for your help. Producercache have stopped growing.And i have configured onException() to be route specific. I will monitor it through the night and see if everything is fine. On a different note,when would these fixes make into main release/tag?Because currently i have manually checked out t

Converting message body after GroupedExchangeAggregationStrategy

eam.WrappedInputStream which i cant access. So all i want is within each of the exchange present in the list,i want to body to be of type String.Is it possible? Thanks Suman -- View this message in context: http://camel.465427.n5.nabble.com/Converting-message-body-after-GroupedExchangeAggregationS

Re: Converting message body after GroupedExchangeAggregationStrategy

Thanks. I have tried it but the dsl doesn't compile(added the one in bold) from("direct:getlivestreaminfo").startupOrder(2) .recipientList().method(messageRouter, "routeTo").parallelProcessing().*convertBodyTo(String.class)*.aggregationStrategy(new GroupedExchangeAggregationStrateg

Re: Converting message body after GroupedExchangeAggregationStrategy

I tried this but no luck...In my receipient list,the list of recipients are a comma separated HTTP URLs.. So what iam trying to do is make a parallel request to bunch of HTTP urls and than try to process them in the processor(eventStreamedAggregationProcessor).Inside that processor, i retrieve list

Re: Converting message body after GroupedExchangeAggregationStrategy

No..The body inside that exchange is of type org.apache.camel.converter.stream.CachedOutputStream$WrappedInputStream@4b8b7245 And when i just debug it inside GroupedExchangeAggregationStrategy and evaluate newexchange using newExchange.getIn().getBody(String.class),its returning empty string.("") S

Re: Converting message body after GroupedExchangeAggregationStrategy

Sorry for confusion..I just debugged inside that GroupedExchangeAggregationStrategy to see what newExchange value has..Anyways in order to avoid confusion i created a dummy one..But still the problem persists... public class MyAggregationStrategy implements AggregationStrategy { @Override

Re: Converting message body after GroupedExchangeAggregationStrategy

Hello, I tried putting implementation inside custom AggregationStrategy and it seems to be working.I dont know why i was getting empty string when i did debug this newexchange object in intellij. Thanks for your help public class MyAggregationStrategy implements AggregationStrategy { @Override