Re: sftp - Exception during concurent execution of sftp endpoint

2014-12-28 Thread eswar
Yes I ddnt find more precise logging than the DEBUG statement in case of an issue. If file gets transmitted properly then I dont get this message instead I get "Wrote file" from RemoteFileProducer. as you see below thread#31 is writing the file file1.dat without issues.But with Thread#27 I see an

Re: sftp - Exception during concurent execution of sftp endpoint

2014-12-25 Thread eswar
Thanks Jens. Yes we have seda queue implemented for certain use cases but for this issue we would end up processing the files concurrently from two different routes using the same endpoint. so ideally i would either need to use sftp component or need to create a custom bean to do sftp. -- View t

Re: sftp - Exception during concurent execution of sftp endpoint

2014-12-25 Thread eswar
Thanks Claus. Yes I use same user to login but that doesnt seem to be an issue as I have custom JSch class that connects to more than 10 sessions concurrently. Problem here though is that when an issue happens in file transmission the route is not stopped instead it keeps continuing and there is j

sftp - Exception during concurent execution of sftp endpoint

2014-12-24 Thread eswar
Hi - I do not get this exception all the time. but happens occasionally. Two routes are using the same sftp endpoint to send files to same server. when both the routes are processing concurrently, the first route is connected and transmitting the file, this first thread is pushed out and the sec

Re: convertBody - To SFTP component

2014-06-28 Thread eswar
thanks Claus, if I transform using simple predicate the map value gets converted into String and get sent as File contents, in this case file content is "C:/Temp/Test.txt". So I had to write a bean to convert this using FileInputStream and I am able to successfully send over. But this original file

Re: convertBody - To SFTP component

2014-06-26 Thread eswar
hi Claus - But I do not want to send the message body as is. For ex., I have a message body of type HashMap as {"Path", "C:/Temp/Test.txt"}. Now I need to send the file mentioned in the path using the sftp component. So I was thinking this HashMap should be converted into File so that sftp compon

Re: convertBody - To SFTP component

2014-06-26 Thread eswar
Thanks Rajesh - but as mentioned above I do not want to transfer the message body but rather need to read the body and determine the file to be transfered -- View this message in context: http://camel.465427.n5.nabble.com/convertBody-To-SFTP-component-tp5752815p5752847.html Sent from the Camel

convertBody - To SFTP component

2014-06-25 Thread eswar
hi - I have a message with body content with string value of file name and directory in it. That I need to send to a different server using sftp component. I am sure we need to convert the message body to a File class to be able to send it using the sftp, do we need to scan through the file to co

Re: Bean MethodNotFound Exception though it looks correct

2014-03-01 Thread eswar
sorry, never mind I was using a wrong signature which I fixed and its working now. -- View this message in context: http://camel.465427.n5.nabble.com/Bean-MethodNotFound-Exception-though-it-looks-correct-tp5748110p5748171.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Bean MethodNotFound Exception though it looks correct

2014-03-01 Thread eswar
hi Ceposta- Yes I have defined this method camel1 in interface1 and then implemented in the class - project. hence i was thinking the testBean should be able to access the camel1 method as defined in the interface. But i am still getting this error, any insight you can offer would be helpful. thank

Bean MethodNotFound Exception though it looks correct

2014-02-28 Thread eswar
hi - this looks obvious but I am not sure if Camel has any restrictions in using the bean which is defined with parent and as singleton. I m using Camel 2.12.2 and this works all fine if I use a simple class(without any superclass) with a method in it. Also I do have AOP's defined on certain metho

Re: Resume an Endpoint in a Route

2014-02-13 Thread eswar
Ok I was trying to accopmlish this without using RouteBuilder class as I dont want to use both Spring XML and Java DSL to define routes. And in Spring XML I dont see an option to set property - routeStartDate in SimpleScheduledRoutePolicy class at runtime. Hence my soluton looks like the one whic

Re: Resume an Endpoint in a Route

2014-02-13 Thread eswar
Yes I looked into SimpleScheduleRoutePolicy, the problem is the time comes from DB which is a dynamic value, and I use Spring XML for routes. so I was not sure on how to attach the dynamically created RoutePolicy reference in the route during the runtime. -- View this message in context: http:/

Re: Resume an Endpoint in a Route

2014-02-12 Thread eswar
Ok here is what I have done - route 1 - from dir to validate route 2 from validate bean ref=delay to db load to processcomplete Inside the Bean I have stopped the route, and I used Quartz API's scheduler to trigger the validate endpoint at a specific time of the day using the same exchan

Re: Resume an Endpoint in a Route

2014-02-12 Thread eswar
more specifically, I am not sure if we can do something like this, which is to resume the route after a delay. I am not able to use RoutingPolicy as the time is a dynamic component and my routes are defined in the Spring XML. Processor(Exchange exchange) { exchange.setProperty(exchange.ROUTE_STOP

Re: Resume an Endpoint in a Route

2014-02-12 Thread eswar
Thanks Andrzej, I think asynchronous delayer could be an option, will try that. And yes Queues would be an overhead here. -- View this message in context: http://camel.465427.n5.nabble.com/Resume-an-Endpoint-in-a-Route-tp5747151p5747213.html Sent from the Camel - Users mailing list archive at N

Resume an Endpoint in a Route

2014-02-11 Thread eswar
Hi - In the below route, I have interceptors defined which gets invoked before each of these endpoints to enrich the message. from {file:location} to validate to DBLoad to processcomplete My requirement is that validation should complete as soon as file arrives but file load in Endpoint "DBLoad"