Hi

If its possible I suggest to try with a newer Camel release to see if
that helps.

Camel 2.7 is no longer supported by Apache.

Though you use a FuseSource version which is still in support by FuseSource.
So if you are a subscriber then you can get in touch with them to get help asap.




On Fri, Sep 14, 2012 at 6:20 PM, jmh <[email protected]> wrote:
> Hi Claus,
>
>
>
> Here is the logs,
>
>
>
> I don't see that the FTP transfer is stopped after the 20 sec timeout
>
>
>
> Any idea ?
>
>
>
> J-M
>
>
>
> 17:53:06,955 | TRACE | d #342 - Threads | RemoteFileProducer               | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Writing using 
> tempNameFile: test/incoming/IB_20120914113923966UP.tmp
>
> 17:53:06,955 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> existsFile(test/incoming/IB_20120914113923966UP.zip)
>
> 17:53:07,002 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Existing file: ., 
> target file: test/incoming/A2_20120913155802716-20120913155654UP.zip
>
> 17:53:07,002 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Existing file: .., 
> target file: test/incoming/A2_20120913155802716-20120913155654UP.zip
>
> 17:53:07,002 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Existing file: 
> 04-06-09, target file: test/incoming/A2_20120913155802716-20120913155654UP.zip
>
> 17:53:07,002 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> existsFile(test/incoming/A2_20120913155802716-20120913155654UP.tmp)
>
> 17:53:07,002 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Existing file: ., 
> target file: test/incoming/IB_20120914113923966UP.zip
>
> 17:53:07,002 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Existing file: .., 
> target file: test/incoming/IB_20120914113923966UP.zip
>
> 17:53:07,002 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Existing file: 
> 04-06-09, target file: test/incoming/IB_20120914113923966UP.zip
>
> 17:53:07,002 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> existsFile(test/incoming/IB_20120914113923966UP.tmp)
>
> 17:53:07,033 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Existing file: ., 
> target file: test/incoming/A2_20120913155802716-20120913155654UP.tmp
>
> 17:53:07,033 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Existing file: ., 
> target file: test/incoming/IB_20120914113923966UP.tmp
>
> 17:53:07,033 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Existing file: .., 
> target file: test/incoming/A2_20120913155802716-20120913155654UP.tmp
>
> 17:53:07,033 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Existing file: .., 
> target file: test/incoming/IB_20120914113923966UP.tmp
>
> 17:53:07,033 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Existing file: 
> 04-06-09, target file: test/incoming/A2_20120913155802716-20120913155654UP.tmp
>
> 17:53:07,033 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Existing file: 
> 04-06-09, target file: test/incoming/IB_20120914113923966UP.tmp
>
> 17:53:07,033 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> buildDirectory(test/incoming,false)
>
> 17:53:07,033 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> buildDirectory(test/incoming,false)
>
> 17:53:07,033 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | getCurrentDirectory()
>
> 17:53:07,033 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | getCurrentDirectory()
>
> 17:53:07,064 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> changeCurrentDirectory(/pub)
>
> 17:53:07,064 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> changeCurrentDirectory(/pub)
>
> 17:53:07,064 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Changing directory: /
>
> 17:53:07,064 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Changing directory: /
>
> 17:53:07,064 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Changing directory: pub
>
> 17:53:07,064 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Changing directory: pub
>
> 17:53:07,080 | TRACE | d #341 - Threads | RemoteFileProducer               | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | About to write 
> [test/incoming/A2_20120913155802716-20120913155654UP.tmp] to 
> [Endpoint[sftp://[email protected]:22/test/incoming?binary=true&disconnect=true&maximumReconnectAttempts=0&password=******&separator=UNIX&tempFileName=%24%7Bfile%3Aname.noext%7D.tmp]]
>  from exchange [Exchange[Message: [Body is instance of java.io.InputStream]]]
>
> 17:53:07,080 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> storeFile(test/incoming/A2_20120913155802716-20120913155654UP.tmp)
>
> 17:53:07,080 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | getCurrentDirectory()
>
> 17:53:07,080 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> changeCurrentDirectory(test/incoming)
>
> 17:53:07,080 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Changing directory: test
>
> 17:53:07,095 | TRACE | d #342 - Threads | RemoteFileProducer               | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | About to write 
> [test/incoming/IB_20120914113923966UP.tmp] to 
> [Endpoint[sftp://[email protected]:22/test/incoming?binary=true&disconnect=true&maximumReconnectAttempts=0&password=******&separator=UNIX&tempFileName=%24%7Bfile%3Aname.noext%7D.tmp]]
>  from exchange [Exchange[Message: [Body is instance of java.io.InputStream]]]
>
> 17:53:07,095 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> storeFile(test/incoming/IB_20120914113923966UP.tmp)
>
> 17:53:07,095 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | getCurrentDirectory()
>
> 17:53:07,095 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> changeCurrentDirectory(test/incoming)
>
> 17:53:07,095 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Changing directory: test
>
> 17:53:07,111 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Changing directory: 
> incoming
>
> 17:53:07,111 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Changing directory: 
> incoming
>
> 17:53:07,127 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> doStoreFile(IB_20120914113923966UP.tmp)
>
> 17:53:07,127 | TRACE | d #341 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> doStoreFile(A2_20120913155802716-20120913155654UP.tmp)
>
> 17:54:00,366 | INFO  | Timer-1          | OsgiBundleXmlApplicationContext  | 
> 70 - org.springframework.context - 3.0.5.RELEASE | Closing 
> OsgiBundleXmlApplicationContext(bundle=up2sftp, 
> config=osgibundle:/META-INF/spring/*.xml): startup date [Fri Sep 14 17:53:01 
> CEST 2012]; root of context hierarchy
>
> 17:54:00,382 | INFO  | Timer-1          | DefaultListableBeanFactory       | 
> 68 - org.springframework.beans - 3.0.5.RELEASE | Destroying singletons in 
> org.springframework.beans.factory.support.DefaultListableBeanFactory@7c9ae7a8:
>  defining beans 
> [org.springframework.context.annotation.internalConfigurationAnnotationProcessor,org.springframework.context.annotation.internalAutowiredAnnotationProcessor,org.springframework.context.annotation.internalRequiredAnnotationProcessor,org.springframework.context.annotation.internalCommonAnnotationProcessor,properties,up2sftpContext:beanPostProcessor,up2sftpContext,shutdown,mainRoutes,onRedeliveryProcessor,sendMailToTechnicalSupport,jasypt,org.springframework.beans.factory.config.PropertyPlaceholderConfigurer#0];
>  root of factory hierarchy
>
> 17:54:00,413 | INFO  | Timer-1          | OsgiSpringCamelContext           | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Apache Camel 
> 2.7.1-fuse-00-43 (CamelContext:up2sftpContext) is shutting down
>
> 17:54:00,413 | INFO  | Timer-1          | DefaultShutdownStrategy          | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Starting to graceful 
> shutdown 2 routes (timeout 20 seconds)
>
> 17:54:00,413 | INFO  | 3 - ShutdownTask | DefaultShutdownStrategy          | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Route: up2sftp.sender 
> suspended and shutdown deferred, was consuming from: 
> Endpoint[file://F:/SmixData/hom/app/up2sftp/inboxDir?delay=60000&delete=true&include=%28%3Fi%29.*%28%5C.xml%29%24%7C%28%3Fi%29.*%28%5C.zip%29%24&initialDelay=2000]
>
> 17:54:00,429 | INFO  | 3 - ShutdownTask | DefaultShutdownStrategy          | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Route: 
> up2sftp.sendMailToTechnicalSupport suspension deferred.
>
> 17:54:00,429 | INFO  | 3 - ShutdownTask | DefaultShutdownStrategy          | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Waiting as there are 
> still 2 inflight and pending exchanges to complete, timeout in 20 seconds.
>
> 17:54:10,367 | ERROR | Thread-152       | RunnableTimedExecution           | 
> 85 - org.springframework.osgi.extender - 1.2.1 | Closing runnable for context 
> OsgiBundleXmlApplicationContext(bundle=up2sftp, 
> config=osgibundle:/META-INF/spring/*.xml) did not finish in 10000ms; consider 
> taking a snapshot and then shutdown the VM in case the thread still hangs
>
>
>
> 17:54:19,446 | INFO  | 3 - ShutdownTask | DefaultShutdownStrategy          | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Waiting as there are 
> still 2 inflight and pending exchanges to complete, timeout in 1 seconds.
>
> 17:54:20,431 | WARN  | Timer-1          | DefaultShutdownStrategy          | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Timeout occurred. Now 
> forcing the routes to be shutdown now.
>
> 17:54:20,431 | WARN  | 3 - ShutdownTask | DefaultShutdownStrategy          | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Interrupted while 
> waiting during graceful shutdown, will force shutdown now.
>
> 17:54:20,431 | INFO  | 3 - ShutdownTask | DefaultShutdownStrategy          | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Route: up2sftp.sender 
> preparing to shutdown complete.
>
> 17:54:20,431 | INFO  | Timer-1          | DefaultShutdownStrategy          | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Graceful shutdown of 2 
> routes completed in 20 seconds
>
> 17:54:20,431 | INFO  | 3 - ShutdownTask | DefaultShutdownStrategy          | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Route: 
> up2sftp.sendMailToTechnicalSupport preparing to shutdown complete.
>
> 17:54:20,431 | INFO  | 3 - ShutdownTask | DefaultShutdownStrategy          | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Route: up2sftp.sender 
> shutdown complete.
>
> 17:54:20,431 | INFO  | 3 - ShutdownTask | DefaultShutdownStrategy          | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Route: 
> up2sftp.sendMailToTechnicalSupport shutdown complete.
>
> 17:54:20,431 | WARN  | Timer-1          | DefaultInflightRepository        | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Shutting down while 
> there are still 2 in flight exchanges.
>
> 17:54:20,447 | INFO  | Timer-1          | OsgiSpringCamelContext           | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Uptime: 1 minute
>
> 17:54:20,447 | INFO  | Timer-1          | OsgiSpringCamelContext           | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Apache Camel 
> 2.7.1-fuse-00-43 (CamelContext: up2sftpContext) is shutdown in 20.034 seconds
>
> 17:54:20,447 | INFO  | Timer-1          | ContextLoaderListener            | 
> 85 - org.springframework.osgi.extender - 1.2.1 | Application context 
> succesfully closed (OsgiBundleXmlApplicationContext(bundle=up2sftp, 
> config=osgibundle:/META-INF/spring/*.xml))
>
> 17:54:51,340 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | 
> changeCurrentDirectory(/pub)
>
> 17:54:51,340 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Changing directory: /
>
> 17:54:51,372 | TRACE | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Changing directory: pub
>
> 17:54:51,418 | DEBUG | d #342 - Threads | RemoteFileProducer               | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Wrote 
> [test/incoming/IB_20120914113923966UP.tmp] to 
> [Endpoint[sftp://[email protected]:22/test/incoming?binary=true&disconnect=true&maximumReconnectAttempts=0&password=******&separator=UNIX&tempFileName=%24%7Bfile%3Aname.noext%7D.tmp]]
>
> 17:54:51,418 | TRACE | d #342 - Threads | RemoteFileProducer               | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Renaming file: 
> [test/incoming/IB_20120914113923966UP.tmp] to: 
> [test/incoming/IB_20120914113923966UP.zip]
>
> 17:54:51,418 | DEBUG | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | Renaming file: 
> test/incoming/IB_20120914113923966UP.tmp to: 
> test/incoming/IB_20120914113923966UP.zip
>
> 17:54:51,481 | TRACE | d #342 - Threads | RemoteFileProducer               | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | postWriteCheck 
> disconnect from: 
> Endpoint[sftp://[email protected]:22/test/incoming?binary=true&disconnect=true&maximumReconnectAttempts=0&password=******&separator=UNIX&tempFileName=%24%7Bfile%3Aname.noext%7D.tmp]
>
> 17:54:51,481 | DEBUG | d #342 - Threads | RemoteFileProducer               | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Disconnecting from: 
> Endpoint[sftp://[email protected]:22/test/incoming?binary=true&disconnect=true&maximumReconnectAttempts=0&password=******&separator=UNIX&tempFileName=%24%7Bfile%3Aname.noext%7D.tmp]
>
> 17:54:51,481 | INFO  | d #342 - Threads | SftpOperations                   | 
> 225 - org.apache.camel.camel-ftp - 2.7.1.fuse-00-43 | JSCH -> Disconnecting 
> from ftp.unifiedpost.com port 22
>
> 17:54:51,497 | WARN  | d #342 - Threads | GenericFileOnCompletion          | 
> 77 - org.apache.camel.camel-core - 2.7.1.fuse-00-43 | Rollback file strategy: 
> org.apache.camel.component.file.strategy.GenericFileDeleteProcessStrategy@1b2501e7
>  for file: 
> GenericFile[F:\SmixData\hom\app\up2sftp\inboxDir\IB_20120914113923966UP.zip]
>
>
>
> De : Claus Ibsen-2 [via Camel] 
> [mailto:[email protected]]
> Envoyé : vendredi 14 septembre 2012 14:20
> À : HERZET Jean-Marc
> Objet : Re: Cannot stop inputstream during ftp transfer
>
>
>
> On Fri, Sep 14, 2012 at 1:18 PM, jmh <[hidden email]> wrote:
>
>
>> Hi Calus,
>>
>> I use Camel 2.7.1
>>
>> Yes, Camel is embedded in OSGi  container Felix
>> (apache-servicemix-4.4.0-fuse-00-43)
>>
>> I stop Camel with the OSGi command "stop bundleId" so the JVM is still
>> running
>>
>
>
> Can you enable DEBUG or TRACE logging on the camel-ftp component.
> Would be interresting to see when the camel is forced shutdown due the
> 20 sec timeout, if the ftp producer (the channel = the ftp client) is
> being disconnected and stopped as well.
>
> Also I wonder if the ftp client suports that, eg to interrupt a file
> transfer from another thread.
>
>
>> J-M
>>
>>
>>
>> --
>> View this message in context: 
>> http://camel.465427.n5.nabble.com/Cannot-stop-inputstream-during-ftp-transfer-tp5719356p5719361.html
>> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>
>
> --
> Claus Ibsen
> -----------------
> FuseSource
> Email: [hidden email]
> Web: http://fusesource.com
> Twitter: davsclaus, fusenews
> Blog: http://davsclaus.com
> Author of Camel in Action: http://www.manning.com/ibsen
>
>
>
> ________________________________
>
> If you reply to this email, your message will be added to the discussion 
> below:
>
> http://camel.465427.n5.nabble.com/Cannot-stop-inputstream-during-ftp-transfer-tp5719356p5719363.html
>
> To unsubscribe from Cannot stop inputstream during ftp transfer, click here 
> <http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=5719356&code=amVhbm1hcmMuaGVyemV0QG5yYi5iZXw1NzE5MzU2fC0xMTMzNjIyMTc4>
>  .
> NAML 
> <http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml>
>
>
> -------------------------------------------------------------------
> GreeNRB
> NRB considers its environmental responsibility and goes for green IT. May we 
> ask you to consider yours before printing this email?
>
> This e-mail and any attachments, which may contain information that is 
> confidential and/or protected by intellectual property rights, are intended 
> for the exclusive use of the above-mentioned addressee(s). Any use (including 
> reproduction, disclosure and whole or partial distribution in any form 
> whatsoever) of their content is prohibited without prior authorization of 
> NRB. If you have received this message by error, please contact the sender 
> promptly by resending this e-mail back to him (her), or by calling the above 
> number. Thank you for subsequently deleting this e-mail and any files 
> attached thereto.
> -------------------------------------------------------------------
>
>
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Cannot-stop-inputstream-during-ftp-transfer-tp5719356p5719385.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-----------------
FuseSource
Email: [email protected]
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen

Reply via email to