camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nikhilesh <nikhiles...@gmail.com>
Subject Camel SFTP,quartz2 component gives:Cannot retrieve file :caused by GenericFileOperationFailedException,when polling multiple files from sftp
Date Fri, 22 Apr 2016 19:56:48 GMT
*I'm trying to poll files from sftp location using the below camel route and
using quartz2 scheduler, after polling couple of files i'm getting a
GenricFileOpertaionFailedException caused by java.io.IOException: Pipe
closed*
JaxbDataFormat dataFormat = new JaxbDataFormat(); 
dataFormat.setContext(JAXBContext.newInstance(MyBean.class));     
from(sftphost + sourcedirpath +                           "?password=" +
password                            + "&username=" + userName                        
  
+ "&include=" + filePattern                          +
"&localWorkDirectory=" + localWorkingDirectory                          +
"&flatten=true"                          + "&delete=true"                        

+ "&scheduler=quartz2"                          + "&scheduler.cron=0/45 * *
* * ?"                           + "&stepwise=false"                         
+ "&disconnect=true")                  .onException(Exception.class)                 
   
.to(sftphost + errdirpath + "?password=" + password + "&username=" +
userName+"&disconnect=true")                      .handled(true)                     
.end()                  .log(LoggingLevel.INFO, "Processing File :
${file:onlyname}").log(LoggingLevel.INFO, "Before Unmarshalling
XML").unmarshal(dataFormat)                  .log(LoggingLevel.INFO, "after
UnMarshalling the XML").beanRef("service", "processData(${body},
${file:name})")                  .to(sftphost + processedDirPAth +
"?password=" + password + "&username=" + userName+ "&disconnect=true");
*I face this issue only when I use the quartz2 Scheduler. The above camel
route works completely fine when I use the '&delay=10000' parameter in the
camel route.*
Error Stacktrace:2016-04-22 10:33:15,634 | WARN  | terface_Worker-1 |
SftpConsumer                    ]    | ?                                    
? | 264 - 1.0.0.SNAPSHOT | Error processing file
RemoteFile[/home/source/file_one.XML    ] due to Cannot retrieve file:
/home/source/file_one.XML. Caused by:
[org.apache.camel.component.file.GenericFileOperat    ionFailedException -
Cannot retrieve file: /home/source/file_one.XML]   
org.apache.camel.component.file.GenericFileOperationFailedException: Cannot
retrieve file: /home/source/file_one.XML            at
org.apache.camel.component.file.remote.SftpOperations.retrieveFileToFileInLocalWorkDirectory(SftpOperations.java:735)[264:myBundle:1.0.0.SNAPSHOT]
          
at
org.apache.camel.component.file.remote.SftpOperations.retrieveFile(SftpOperations.java:591)[264:myBundle:1.0.0.SNAPSHOT]
          
at
org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:396)[264:myBundle:1.0.0.SNAPSHOT]
          
at
org.apache.camel.component.file.remote.RemoteFileConsumer.processExchange(RemoteFileConsumer.java:137)[264:myBundle:1.0.0.SNAPSHOT]
          
at
org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:211)[264:myBundle:1.0.0.SNAPSHOT]
          
at
org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:175)[264:myBundle:1.0.0.SNAPSHOT]
          
at
org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:174)[264:myBundle:1.0.0.SNAPSHOT]
          
at
org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:101)[264:myBundle:1.0.0.SNAPSHOT]
          
at
org.apache.camel.pollconsumer.quartz2.QuartzScheduledPollConsumerJob.execute(QuartzScheduledPollConsumerJob.java:59)[264:myBundle:1.0.0.SNAPSHOT]
          
at org.quartz.core.JobRunShell.run(JobRunShell.java:202)[264:myBundle   
:1.0.0.SNAPSHOT]            at
org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:573)[264:myBundle:1.0.0.SNAPSHOT]
  
Caused by: 4:            at
com.jcraft.jsch.ChannelSftp._get(ChannelSftp.java:1160)[264:myBundle:1.0.0.SNAPSHOT]     
     
at
com.jcraft.jsch.ChannelSftp.get(ChannelSftp.java:1006)[264:myBundle:1.0.0.SNAPSHOT]      
    
at com.jcraft.jsch.ChannelSftp.get(ChannelSftp.java:984)[264:myBundle   
:1.0.0.SNAPSHOT]            at
org.apache.camel.component.file.remote.SftpOperations.retrieveFileToFileInLocalWorkDirectory(SftpOperations.java:724)[264:myBundle:1.0.0.SNAPSHOT]
          
... 10 more    Caused by: java.io.IOException: Pipe closed            at
java.io.PipedInputStream.read(PipedInputStream.java:307)[:1.8.0_45]           
at java.io.PipedInputStream.read(PipedInputStream.java:377)[:1.8.0_45]           
at
com.jcraft.jsch.ChannelSftp.fill(ChannelSftp.java:2882)[264:myBundle:1.0.0.SNAPSHOT]     
     
at
com.jcraft.jsch.ChannelSftp.header(ChannelSftp.java:2908)[264:myBundle:1.0.0.SNAPSHOT]   
       
at
com.jcraft.jsch.ChannelSftp._get(ChannelSftp.java:1025)[264:myBundle:1.0.0.SNAPSHOT]     
     
... 13 moreI have not used any other IO streams which are to be closed in
the camel route. Help is much Appreciated, Thanks.



--
View this message in context: http://camel.465427.n5.nabble.com/Camel-SFTP-quartz2-component-gives-Cannot-retrieve-file-caused-by-GenericFileOperationFailedExceptiop-tp5781587.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message