Re: camel seda queue log

2016-09-14 Thread Claus Ibsen
Yes the multicast does a shallow copy so its the same reference. You can use onPrepareRef where you can write some code that performs a deep copy of the message. http://camel.apache.org/multicast On Wed, Sep 14, 2016 at 11:31 PM, Akram wrote: > I have tried using default queue mechanism. There

How to launch

2016-09-14 Thread A. Corral
Hi, I investigated and I would like to know how I sould do the next EIP I have 20 scheduler task that launch a task, each with different data but using the same component. The component is a custom component that connects to a remote service to read data. I would like to instantiate only one comp

Re: camel seda queue log

2016-09-14 Thread Akram
I have tried using default queue mechanism. There also i am seeing the same log "using shared queue". So trying to understand what it actually does mean. Also I am sending same object to two different seda routes using multicast. I wants to understand whether both routes use same object reference,

Re: camel seda queue log

2016-09-14 Thread Brad Johnson
https://github.com/apache/camel/blob/master/camel-core/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java By the way if you look in there you can see where the log statement comes from in the createQueue method. On Wed, Sep 14, 2016 at 3:40 PM, Akram wrote: > I am using simple seda

Re: camel seda queue log

2016-09-14 Thread Brad Johnson
I'm not sure what is happening inside your queueFactory but is there a particular reason you need a queue factory and not just use the default queue? There could be, obviously, if you need to create some sort of priority queue or other mechanism but it isn't necessary otherwise. Brad On Wed, Sep

camel seda queue log

2016-09-14 Thread Akram
I am using simple seda route and seeing that seda is using shared queue in log. Endpoint Endpoint[seda://elasticSearchStore?concurrentConsumers=5&queueFactory=%23elasticsearchStoreLinkedQueue] is using shared queue: seda://elasticSearchStore with size: 2147483647 2016-09-14 21:33:51,952 INFO Seda

Re: Fuse Blueprint properties override

2016-09-14 Thread Brad Johnson
As Grzegorz pointed out you have to have the reload flag in to hot swap values. And it's important that you make sure you specify the 1.1.0 of cm in your header as the reload doesn't work earlier. Having said that, if you change the value in the .cfg file and then start you Fuse instance it shoul

Issue with Request-Reply pattern in JMS camel 2.10

2016-09-14 Thread ravi21588
Hi All, Iam trying to achieve the below scenario. I have a switchyard application with soap binding which puts the request in request Queue and waits for the response from response queue,request-reply pattern.i have another route In-only mep which picks the message from a queue process it and put t

Re: Fuse Blueprint properties override

2016-09-14 Thread Grzegorz Grzybek
Hello Did you use update-strategy="reload" in ? See technical explanation here: http://ggrzybek.blogspot.com/2015/12/camel-blueprint-test-support.html regards Grzegorz Grzybek 2016-09-14 11:47 GMT+02:00 owain : > Hi, > > In Fuse it looks as though if you have a property set in xml in > cm:prope

Fuse Blueprint properties override

2016-09-14 Thread owain
Hi, In Fuse it looks as though if you have a property set in xml in cm:property-placeholder then you cannot override it in persistent.id.cfg file in /etc. I could see the properties in there but they appeared not to be used by the route, it just used the ones set in the xml. Is this true, if so

Concurrent modification while ingesting to elasticsearch

2016-09-14 Thread Akram
I have a route which will ingest data to elasticsearch. But it is throwing concurrentModificationException while ingesting to elasticsearch from("file://somefile") .multicast() .to("seda:someroute?concurrentConsumers=8","seda:elasticsearchStore?concurrentConsumers=8"); from("seda:elasticsear