svn commit: r1162676 - /synapse/trunk/java/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java

[hiranya]

Author: hiranya
Date: Mon Aug 29 08:34:49 2011
New Revision: 1162676

URL: http://svn.apache.org/viewvc?rev=1162676&view=rev
Log:
Fixing SYNAPSE-793. Committing patch from Sadeep.

Modified:
    
synapse/trunk/java/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java

Modified: 
synapse/trunk/java/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java?rev=1162676&r1=1162675&r2=1162676&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java
 Mon Aug 29 08:34:49 2011
@@ -187,18 +187,23 @@ public class VFSTransportListener extend
                 wasError = false;
 
             } catch (FileSystemException e) {
-                log.error("cannot resolve fileObject", e);
-                if (maxRetryCount <= retryCount)
-                    processFailure("cannot resolve fileObject repeatedly: "
-                            + e.getMessage(), e, entry);
-                return;
+                if (retryCount >= maxRetryCount) {
+                    processFailure("Repeatedly failed to resolve the file URI: 
" +
+                            VFSUtils.maskURLPassword(fileURI), e, entry);
+                    return;
+                } else {
+                    log.warn("Failed to resolve the file URI: " +
+                            VFSUtils.maskURLPassword(fileURI) + ", in attempt 
" + retryCount +
+                            ", " + e.getMessage() + " Retrying in " + 
reconnectionTimeout +
+                            " milliseconds.");
+                }
             }
 
             if (wasError) {
                 try {
                     Thread.sleep(reconnectionTimeout);
                 } catch (InterruptedException e2) {
-                    e2.printStackTrace();
+                    log.error("Thread was interrupted while waiting to 
reconnect.", e2);
                 }
             }
         }