camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Claus Ibsen <claus.ib...@gmail.com>
Subject Re: Camel SFTP move is failing in new fuse
Date Thu, 05 Apr 2012 12:23:11 GMT
Hi

This mailing list is for Apache Camel.

You can use FuseSource forum / their support. To get help with the Fuse ESB.
http://fusesource.com/forums/index.jspa

That said can you post the full FTP uri, without the ${ } placeholders.
This help us understand how you have configured it.

And make sure whether the starting directory is absolute or not. eg
the number of slashes determines that.

And do you have the directories already on the server
/source/notprocessed



On Wed, Apr 4, 2012 at 4:59 PM, kanmisc <kangotam@gmail.com> wrote:
> 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.



-- 
Claus Ibsen
-----------------
CamelOne 2012 Conference, May 15-16, 2012: http://camelone.com
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

Mime
View raw message