camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jmh <jeanmarc.her...@nrb.be>
Subject RE: Cannot stop inputstream during ftp transfer
Date Fri, 14 Sep 2012 16:20:27 GMT
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://ethias@ftp.unifiedpost.com: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://ethias@ftp.unifiedpost.com: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://ethias@ftp.unifiedpost.com: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://ethias@ftp.unifiedpost.com: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://ethias@ftp.unifiedpost.com: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:ml-node+s465427n5719363h2@n5.nabble.com] 
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.
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message