camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kanmisc <kango...@gmail.com>
Subject Camel SFTP move is failing in new fuse
Date Wed, 04 Apr 2012 14:59:20 GMT
Hi

I have the below route to read the file from ftp server and process it. It
moves the file to /processed/ folder or /notprocessed/ folder.

/from("sftp://{{ftp.username}}@{{ftp.host}}{{ftp.loc.source}}?password={{ftp.pwd}}&filter=#sourceFileFilter&consumer.delay={{ftp.delay}}&move={{ftp.loc.processed}}&moveFailed={{ftp.loc.notprocessed}}")
.to("log:com.nokia.marketing.nmg.impl?level=INFO")
.beanRef("processFeedbackLoop")
.stop();/

This was working fine in /apache-servicemix-4.3.0-fuse-00-00/ for one year
now. And we upgraded the fuse to /apache-servicemix-4.4.1-fuse-01-20/ now
and it fails. 

It reads the file and processes it but while moving to /processed /or
/notprocessed/ it complains as below permission denied error. Below is the
exception,

/17:39:29,664 | ERROR | source/landing | GenericFileOnCompletion |
ache.camel.processor.CamelLogger  232 | 79 - org.apache.camel.camel-core -
2.8.0.fuse-01-20 | Caused by:
[org.apache.camel.component.file.GenericFileOperationFailedException -
Cannot create directory: /source/notprocessed (could be because of denied
permissions)]
org.apache.camel.component.file.GenericFileOperationFailedException: Cannot
create directory: /source/notprocessed (could be because of denied
permissions)
        at
org.apache.camel.component.file.strategy.GenericFileProcessStrategySupport.renameFile(GenericFileProcessStrategySupport.java:92)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy.rollback(GenericFileRenameProcessStrategy.java:68)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.component.file.GenericFileOnCompletion.processStrategyRollback(GenericFileOnCompletion.java:154)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.component.file.GenericFileOnCompletion.onCompletion(GenericFileOnCompletion.java:89)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.component.file.GenericFileOnCompletion.onFailure(GenericFileOnCompletion.java:58)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.util.UnitOfWorkHelper.doneSynchronizations(UnitOfWorkHelper.java:53)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.impl.DefaultUnitOfWork.done(DefaultUnitOfWork.java:208)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.processor.UnitOfWorkProcessor.doneUow(UnitOfWorkProcessor.java:188)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.processor.UnitOfWorkProcessor.processSync(UnitOfWorkProcessor.java:128)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:104)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:69)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:353)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.component.file.remote.RemoteFileConsumer.processExchange(RemoteFileConsumer.java:94)[174:org.apache.camel.camel-ftp:2.8.0.fuse-01-20]
        at
org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:176)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:137)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:138)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:90)[79:org.apache.camel.camel-core:2.8.0.fuse-01-20]
        at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)[:1.6.0_31]
        at
java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)[:1.6.0_31]
        at
java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)[:1.6.0_31]
        at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98)[:1.6.0_31]
        at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:180)[:1.6.0_31]
        at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:204)[:1.6.0_31]
        at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_31]
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)[:1.6.0_31]
        at java.lang.Thread.run(Thread.java:662)[:1.6.0_31]
/


I have written Junit to upload files to those locations and it worked. Junit
did not have /move, moveFailed/ options. It has just <to
uri="sftp://{{ftp.username}}@{{ftp.host}}{{ftp.loc.processed}}?password={{ftp.pwd}}"/>.
So I am doubting that, is /move/moveFailed/ causing this issue. Any help
appreciated. Thanks in advance.


--
View this message in context: http://camel.465427.n5.nabble.com/Camel-SFTP-move-is-failing-in-new-fuse-tp5618015p5618015.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message