Re: How to get RouteId in a GenericFileFilter ...

2012-12-04 Thread Claus Ibsen
Hi This is not supported; and its not easy doable as its an API breaking to pass in any route information as a new parameter to the interface(s). You can create a generic filter and setup a number of filters with the route id configured. On Wed, Dec 5, 2012 at 8:42 AM, helmut.at

Re: How to get RouteId in a GenericFileFilter ...

2012-12-04 Thread helmut.at.work
Please excuse my poor description of the problem. Second try: In my application I would like to implement a filter for a file consumer, like that: I plan to code a general filter for all/some of my routes. In the filter method I do in the first run something like this: No problem so far. But now

Re: setHeaders when message gets routed to different queues

2012-12-04 Thread Willem jiang
Hi When the message send to the queue, it will marshaled as a stream. And you will get a copy of it from the queue, so when you change the original message headers, it will effect the message which you already send to queue. -- Willem Jiang Red Hat, Inc. FuseSource is now part of Red Hat We

Re: Redirecting a soap request to external webservice

2012-12-04 Thread Willem jiang
Hi Using the payload should work for you, as camel-cxf is try to understand the request. I'm not sure how do you configure the ws-security on the camel-cxf endpoint, but it could easy to configure a generic ws-security interceptor[1] if you don't relay on wssecurity-policy[2]. [1]http://cxf.ap

Re: How to get RouteId in a GenericFileFilter ...

2012-12-04 Thread Christian Müller
I don't think I (and other users) understand what you try to do. Could you share an example with us? Best, Christian On Tue, Dec 4, 2012 at 9:07 PM, helmut.at.work wrote: > appreciated

Re: Setting Header as Xpath expression

2012-12-04 Thread Jason Chaffee
I will debug some more and respond later in the day. It doesn't aways fail with an exception. Often, it just stops processing more messages and I think that is because the javascript expression is failing to return true. The javascript expression is what is setting the headers for correct pagina

Re: Setting Header as Xpath expression

2012-12-04 Thread Christian Müller
Which exception did you get? Can you share the stack trace? Which Camel version do you use? Best, Christian Sent from a mobile device Am 04.12.2012 11:40 schrieb "Jason Chaffee" : > I take that back. It worked one time, but not the next time. However, my > hack works with every run. > > > > On

Re: activemq: reference to connection

2012-12-04 Thread Christian Müller
No. Best, Christian Sent from a mobile device Am 03.12.2012 21:32 schrieb "samslara" : > Hello, > Is there a way from within a Processor to get a reference to the > connection that was used to connect to the broker to fetch the jms message? > For example in the given route: > > > > > Is ther

Dynamic endpoint using Recipient, ExchangeTimedOutException

2012-12-04 Thread lleclerc
Hi, I got 2 separate projects, the project1 is an osgi component that start a CamelContext with routes and use a dynamic recipientList(). On project2, I call addRecipient(Endpoint endpoint) from project1's exported service. In project1, my route is like this : from(sedaEndPointURI

Files not Picked up with doneFile

2012-12-04 Thread yxzhao
Hi All, We have a route to get a set of files being processed together, that are prepared by different processes asynchronously. In order to flag the start, we will put a doneFile to flag all the files are ready to be processed. However, once a while we found some of the files are left there whi

Re: [FTP + ConsumerTemplate] Threads remaining alive

2012-12-04 Thread Aida
Hi, Thank you very much, as you said doing that the threads are cleaned up :) I should have tried that before, my apologies ... I'm sorry to bother you, but after using that approach and consuming files intensively I have seen that sometimes the consumerTemplate cannot be stoppped, and, in that

Re: configure xstream instead of java serialization as default

2012-12-04 Thread Claus Ibsen
On Tue, Dec 4, 2012 at 3:18 PM, prueegg wrote: > Is it somehow possible to configure xstream as object serialization instead > of the java serializiation? > > In my project I have various Object Messages to transfer over JMS. By > default the Obects are serialized with the Java serialization. > Of

Re: camelExclusiveReadLock

2012-12-04 Thread Claus Ibsen
On Tue, Dec 4, 2012 at 3:55 PM, swwyatt wrote: > When the SFTP component writes a file, does it use the > 'camelExclusiveReadLock' extension or is this just for consumer? > Just for consumers. They are read locks, and all apply for consumers only. > > > -- > View this message in context: > htt

camelExclusiveReadLock

2012-12-04 Thread swwyatt
When the SFTP component writes a file, does it use the 'camelExclusiveReadLock' extension or is this just for consumer? -- View this message in context: http://camel.465427.n5.nabble.com/camelExclusiveReadLock-tp5723619.html Sent from the Camel - Users mailing list archive at Nabble.com.

configure xstream instead of java serialization as default

2012-12-04 Thread prueegg
Is it somehow possible to configure xstream as object serialization instead of the java serializiation? In my project I have various Object Messages to transfer over JMS. By default the Obects are serialized with the Java serialization. Of course I could configure the route to do marshalling and u

Re: Redirecting a soap request to external webservice

2012-12-04 Thread David Karlsen
I see that this one refers to a wsdl in the configuration. Would it be feasable to build a generic one that do not need to configure the wsdl. I'd like to build a generic soap router and route based on the contents of a soap header. I tried using CXF in payload and/or message mode, but it either fa

Re: Possible memory leak in org.apache.activemq.pool.PooledSession

2012-12-04 Thread anaCortes
Hi Claus, we are having a similar problem. Our configuration is: - Camel 2.10.1 - ActiveMQ 5.5.1 > In Camel 2.9 you can use replyToType=Exclusive, which would then not have this leak. We cannot use replyToType=Exclusive because we are using a cluster environment, so we have to use shared rep

Re: Test Intercept with adviceWith and http

2012-12-04 Thread Willem jiang
Did you remove the call of mockEndpoints();? -- Willem Jiang Red Hat, Inc. FuseSource is now part of Red Hat Web: http://www.fusesource.com | http://www.redhat.com Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English) http://jnn.javaeye.com (http://jnn.ja

Re: Redirecting a soap request to external webservice

2012-12-04 Thread Willem jiang
Hi, Please take a look at this example[1] [1]http://camel.apache.org/cxf-proxy-example.html -- Willem Jiang Red Hat, Inc. FuseSource is now part of Red Hat Web: http://www.fusesource.com | http://www.redhat.com Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English)

Re: No consumers available for endpoint.

2012-12-04 Thread Bilgin Ibryam
In that case, you should first start routeB, so that when routeA starts its .to("direct:routeB") points to valid consumer in routeB Bilgin On 4 December 2012 12:51, vishalad wrote: > I am sorry, it's a typo mistake, route B should be read as > > public class B extends RouteBuilder{ > @Override >

Redirecting a soap request to external webservice

2012-12-04 Thread nmsrinm
Hi We need to redirect the SOAP request body received from the client side to the external web service(External server). Can anyone suggest which camel component to be used and is it possible to implement in JAVA DSL? Suggest/Mention some suitable example for the same Here i attached a sample cod

Re: No consumers available for endpoint.

2012-12-04 Thread vishalad
I am sorry, it's a typo mistake, route B should be read as public class B extends RouteBuilder{ @Override public void configure() throws Exception { from("direct:routeB") .process(new Processor() { @Override public void process(Exchange exchange) throws Exception {

Re: Thread leak when create pollEnrich

2012-12-04 Thread edvicif
The problem is that I'm consuming through sftp. My problem is that I see that the thread count is increasing with the template and the dynamic routing solution. As the unused endpoint after it consumed the file not free up. I've experienced this with the consumer template as well. Is there a way

Re: No consumers available for endpoint.

2012-12-04 Thread Bart Horré
Do you have a camel context file to start your routes? is route B started in there? To me it seems the configure method of route B is never called On Tue, Dec 4, 2012 at 11:24 AM, Bilgin Ibryam wrote: > Hi Vishal, > > routeB doesn't seem correct to me. At the end of the route, you are > callin

Re: Setting Header as Xpath expression

2012-12-04 Thread Jason Chaffee
I take that back. It worked one time, but not the next time. However, my hack works with every run. On 12/4/12 1:50 AM, "Jason Chaffee" wrote: >If I use String.class instead of Integer.class it works. It could be an >issue with my javascript why the Integer.class didn¹t work. > > > >On 12/4

Re: No consumers available for endpoint.

2012-12-04 Thread Bilgin Ibryam
Hi Vishal, routeB doesn't seem correct to me. At the end of the route, you are calling again the same route: to("direct:routeB") Any reason for that? Bilgin On 4 December 2012 07:25, vishalad wrote: > Hi All, > > I have a route A which is timer based route and gets invoke at server > startup. I

Re: Setting Header as Xpath expression

2012-12-04 Thread Jason Chaffee
If I use String.class instead of Integer.class it works. It could be an issue with my javascript why the Integer.class didn¹t work. On 12/4/12 1:20 AM, "Jason Chaffee" wrote: >Tried that, but for some reason it fails to give me the expected results >as it stops processing after 18,000 records

Re: Setting Header as Xpath expression

2012-12-04 Thread Jason Chaffee
Tried that, but for some reason it fails to give me the expected results as it stops processing after 18,000 records whereas my "hack" finishes correctly after 34254 records. On 12/3/12 11:23 PM, "Christian Müller" wrote: >Indeed, this is clunky... ;-) >You should be able to do >ns.xpath("/soa

Re: Setting Header as Xpath expression

2012-12-04 Thread Jason Chaffee
Tried that, but for some reason it fails to give me the expected results as it stops processing after 18,000 records whereas my "hack" finishes correctly after 34254 records. On 12/3/12 11:19 PM, "Willem jiang" wrote: >Hi, > >You should be able to set the xpath expression result like this >.se