Re: ERROR [org.apache.camel.component.jms.DefaultJmsMessageListenerContainer]

2017-05-08 Thread chandler
Yes, I have a set of routes. One of my camel processors does a JMS request/reply using the org.apache.camel.ProducerTemplate.requestBody(...) see below. I believe 1. The Camel request/reply (InOut) 20 sec default timeout occurs. And the route is terminated. 2. However, the requestBody is still pe

Re: Dynamic "from" and pollEnrich

2017-05-08 Thread souciance
t; Thanks souciance, > yes I have header where I store the date, as per my original post: > > "I want to trigger this route from a restful where the date part of the > file is specified in input i.e. > >template.sendBodyAndHeaders("direct:myRoute", null, "head

Re: jCIFS timeout settings

2017-05-08 Thread Pontus Ullgren
Hi, You can do this either by setting the system property jcifs.smb.client.soTimeout on the JVM level when starting the process that runs your Camel route. Another option is to use a properties file and the set the system property jcifs.properties to point to that file. For more information see t

Re: camel-kafka offset commit

2017-05-08 Thread sma
Thanks, if i want to commit after my process is done and write the result to the output topic, can i do it with kafka-camel, i dont see a way to manually commit offset? Shannon -- View this message in context: http://camel.465427.n5.nabble.com/camel-kafka-offset-commit-tp5798423p5799118.html S

jCIFS timeout settings

2017-05-08 Thread Peter J Nelson
I have a camel route that needs to delete a file over CIFS. For the most part it works, but occasionally, I get a timeout from the CIFS server. jcifs.smb.SmbException: Transport1 timedout waiting for response to SmbComDelete[command=SMB_COM_DELETE,received=false,errorCode=0,flags=0x0018,flags2=0xC

Good / Adviced way to poll an entire folder at scheduled moment

2017-05-08 Thread Jonathan Schoreels
Hi. I would like to know, in your experience, what's the best way to poll an entire folder/remote folder, at an regular interval ? It could seems quite easy, since the the file consumer can be used as a batch consumer, that a scheduler can be used with it, but I have some limitation each time :

Re: Dynamic "from" and pollEnrich

2017-05-08 Thread geppo
Thanks souciance, yes I have header where I store the date, as per my original post: "I want to trigger this route from a restful where the date part of the file is specified in input i.e. template.sendBodyAndHeaders("direct:myRoute", null, "header:date", &

Re: hystrix fallback configuration for camel dynamic router returning multiple endpoints

2017-05-08 Thread nanikpranjith9
Thanks for replying Claus. With the second approach you mentioned having hystrix eip in camel route the dynamic router would trigger all the endpoints even when one endpoint failed which is not desired in the use case i'm trying to solve. And for the first approach it would be helpful if you could

Re: Re throwing exception

2017-05-08 Thread las
I did that but that will still not fail the junit test. I handle an exception in the route using onException processor - the assertion error that's thrown within the onException processor is handled by camel and test is passing all the time. -- View this message in context: http://camel.465427

Re: Re throwing exception

2017-05-08 Thread Claus Ibsen
You need to handle the exception with handled(true) On Mon, May 8, 2017 at 4:31 PM, las wrote: > Can I get a response? > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/Re-throwing-exception-tp5798653p5799108.html > Sent from the Camel - Users mailing list archive at

Re: Re throwing exception

2017-05-08 Thread las
Can I get a response? -- View this message in context: http://camel.465427.n5.nabble.com/Re-throwing-exception-tp5798653p5799108.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Dynamic "from" and pollEnrich

2017-05-08 Thread souciance
One question, Do you have a header where you store the date and you want to use that, or do you want to access the simple language to access current date? If I am not misstaken if it is the former, it should be ${headers.date} and for the latter it should be ${date:now:MMdd} to include year,

Re: Dynamic "from" and pollEnrich

2017-05-08 Thread geppo
Thank you Claus, if I understood right then my route should change like this: from("direct:myRoute") .transacted() .id("MyRoute") .pollEnrich().simple("file://folder?fileName=filename_${header:date}.txt") .process(new MyProcessor()) But nothing changed really.

Re: Dynamic "from" and pollEnrich

2017-05-08 Thread Claus Ibsen
filename_*.txt") > .transacted() > .id("MyRoute") > .process(new MyProcessor); > > I want to trigger this route from a restful where the date part of the file > is specified in input i.e. > >template.sendBodyAndHeaders("direct:myRoute&

Dynamic "from" and pollEnrich

2017-05-08 Thread geppo
ecified in input i.e. template.sendBodyAndHeaders("direct:myRoute", null, "header:date", "20170508") so I've thought I could modify my route so that the input endpoint is dynamic by using pollEnrich i.e. from("direct:myRoute") .transacted() .

Re: Bug in onException with onRedelivery

2017-05-08 Thread Tadayoshi Sato
Hi, I would first check if AnotherException is really thrown from MyProcessor. On Thu, May 4, 2017 at 1:35 AM, Ryan T wrote: > Can someone verify that this is a bug or not? > > > > -- > View this message in context: http://camel.465427.n5.nabble. > com/Bug-in-onException-with-onRedelivery-tp579

Re: How to remove start-up dependency of camel due to Failed to create Producer for endpoint: Endpoint[cxf://bean

2017-05-08 Thread Claus Ibsen
Set the routes to autoStartup=false, and then have your own kind of logic that attempts to start those routes from time to time in case those external systems are not working. On Mon, May 8, 2017 at 6:52 AM, prakash wrote: > Hi , > > We have multiple end points in our application. during the app

Rest DSL - specify charset

2017-05-08 Thread Thomas Weinschenk
Hi, is there a way to specify the charset of the response? My service returns characters like ° or ³ and some clients tend to misinterpret these characters if the charset is not specified (UTF-8 in my case). If I (just) specify the bindingMode as Json as follows... restConfiguration().contextPat