Re: How to set a message header to an object in spring?

2014-02-17 Thread Claus Ibsen
On Tue, Feb 18, 2014 at 5:26 AM, bocamel wrote: > I am trying to pass a DAO object to a processor through message header. But > I cannot find out how to do this in Spring DSL. The following XML does not > work (complaining that no expression found in registry for myDao): > > > > ... > > myDao >

Netty listening producer

2014-02-17 Thread Stijn Haezebrouck
Hello, we need to implement following setup: We have a system to which we need to send data (one way only), but where the other system acts as a TCP/IP client. Hence, we should wait for an incomming TCP/IP connection. Once established, we must send the data over this connection. So with netty, this

How to set a message header to an object in spring?

2014-02-17 Thread bocamel
I am trying to pass a DAO object to a processor through message header. But I cannot find out how to do this in Spring DSL. The following XML does not work (complaining that no expression found in registry for myDao): ... myDao Any help will be greatly appreciated. Thanks! -- View this m

Re: Spring AMQP Apache Camel Component Released

2014-02-17 Thread deckerego
It appears the NPEs are due to a response not being made, either because a) a timeout occurred, b) delivery to the wrong queue or c) a null was actually sent as the endpoint's response. I have a patch now committed to master to resolve the NPE, however it just handles the null in a more sensical w

Re: Spring AMQP Apache Camel Component Released

2014-02-17 Thread muthukumara...@gmail.com
@deckerego I tried to set the reply-timeout as mentioned by "VitorCardoso", but still got the NEP exceptions. -- View this message in context: http://camel.465427.n5.nabble.com/Spring-AMQP-Apache-Camel-Component-Released-tp5027785p5747449.html Sent from the Camel - Users mailing list archive a

Re: Spring AMQP Apache Camel Component Released

2014-02-17 Thread muthukumara...@gmail.com
Thank you Claus Ibsen for sharing the link. I used the endpoint approach to fix this issue. -- View this message in context: http://camel.465427.n5.nabble.com/Spring-AMQP-Apache-Camel-Component-Released-tp5027785p5747448.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: http4 component to convert ANY page encoding into UTF-8

2014-02-17 Thread Willem Jiang
Camel converter can take the encoding into consideration when it converts an input stream into String. I think you can leverage that. Now what we need to do is adding a feature[1] in camel-http component to setup the encoding header of the message if it can tell it from the Http header. [1]https

RE: what does META-INF.cxf mean? in import-package of osgi

2014-02-17 Thread Willem Jiang
It’s camel-cxf bundles, CXF bus can take care of it, you don’t need to specify it in your application bundle. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com(http://willemjiang.blogspot.com/) (English) http://jnn.iteye.com(http://jnn.javaeye.com/

Re: Camel raising Exception for continuous MQTT Publishing

2014-02-17 Thread Christian Posta
Think you can put together a small test case to reproduce? On Mon, Feb 17, 2014 at 5:12 AM, harikrish07121991 wrote: > Updated Camel to its latest SNAPSHOT, but still the same issue persists ... > Let me ask u something , is it the error of Apache Camel not able to process > multiple mqtt streams

Re: Apache Mina2 and HL7 listener

2014-02-17 Thread Bart
So there is no way to get connected to endpoint session using mina2 or somehow with camel? Maybe there is a way to get already created session for specific address and port? I'm really looking for such solution without interfering with camel source code - I've tried and failed... -- View this

Re: Camel raising Exception for continuous MQTT Publishing

2014-02-17 Thread harikrish07121991
Updated Camel to its latest SNAPSHOT, but still the same issue persists ... Let me ask u something , is it the error of Apache Camel not able to process multiple mqtt streams ?/?? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-raising-Exception-for-continuous-MQTT-Pub

http4 component to convert ANY page encoding into UTF-8

2014-02-17 Thread gutsal.arsen
I'm using http4 component. Different pages comes with different encoding. I'd like to analyze either Content-Type header or meta/@http-equiv=Content-Type encoding attribute and convert everything into default UTF-8. How could I do that? Probably patch for http4 component is needed (we could create

Is that possible to remove Interceptor previously applied with AdwiceWith?

2014-02-17 Thread gutsal.arsen
I'm having integration tests which use AdviceWith in each method. Although I've marked them as @DirtiesContext it seems that interceptors previously applied with AdviceWith in one mothod are not removed when other method is called (seems camelContext does not destroy between test methods so multipl

RE: what does META-INF.cxf mean? in import-package of osgi

2014-02-17 Thread nono
on my karaf list|grep cxf , show below, which is higher than 2.6. so i dont need META-INF.cxf anymore? camel-cxf-transport (2.9.0.fuse-70-084) camel-cxf (2.9.0.fuse-70-084) -- View this message in context: http://camel.465427.n5.nabble.com/what-does-META-INF-cxf-mean-in-import-package-of-o

Camel netty response is trimied for large data

2014-02-17 Thread bulutoprak
Hi, I am using netty tcp route to handle requests and return a string message to the clients. The solution is working for most of the case, but recently we noticed that if the returned string is a large string (>2milyon characters) , client socket can read only part of it. On the client, the code

Re: OOM issue due to MemoryIdempotentRepository

2014-02-17 Thread Chirag Dewan
Hi Claus, I had this implementation before. With this I saw an unusual behaviour. A thread was created for every file consumed by the template and even though I called template.doneUoW the thread is not stopped. So if I call doneUoW(and not stop) the thread should be destroyed? And also on d

Re: OOM issue due to MemoryIdempotentRepository

2014-02-17 Thread Chirag Dewan
Hi Claus, I had this implementation before. With this I saw an unusual behaviour. A thread was created for every file consumed by the template and even though I called template.doneUoW the thread is not stopped. So if I call doneUoW(and not stop) the thread should be destroyed? And also on done

Re: OOM issue due to MemoryIdempotentRepository

2014-02-17 Thread Claus Ibsen
On Mon, Feb 17, 2014 at 8:49 AM, Chirag Dewan wrote: > Hi Claus, > > So I dont need to start/stop the template for every file? > > Right now I create a consumerTemplate at satrtup and then on every method > call(responsible for consuming file) I start the template,consume the > file(template.rec