commit 5c6b18a4d660dd488404db46e2ed0b4c9ae2c6c5
author Dalngoda Arachchige Nuwan Rajika Kumarasiri <rajikak@apache.org> Fri Nov 12 04:23:10 2010 +0000
committer Dalngoda Arachchige Nuwan Rajika Kumarasiri <rajikak@apache.org> Fri Nov 12 04:23:10 2010 +0000
tree 5dd84df92fccc6dfb4c426ac0b60a021cce0c64e
parent c2a793afe568de3ce64baea2176b975b6eeeb162

Fixed VFS-341.

git-svn-id: https://svn.apache.org/repos/asf/synapse/branches/commons-vfs-2-synapse-2.0@1034266 13f79535-47bb-0310-9956-ffa450edef68

core/src/main/java/org/apache/commons/vfs/provider/sftp/SftpClientFactory.java

diff --git a/core/src/main/java/org/apache/commons/vfs/provider/sftp/SftpClientFactory.java b/core/src/main/java/org/apache/commons/vfs/provider/sftp/SftpClientFactory.java
index eaa25b5..e59ffdd 100644
--- a/core/src/main/java/org/apache/commons/vfs/provider/sftp/SftpClientFactory.java
+++ b/core/src/main/java/org/apache/commons/vfs/provider/sftp/SftpClientFactory.java
@@ -16,16 +16,12 @@
  */
 package org.apache.commons.vfs.provider.sftp;
 
-import com.jcraft.jsch.JSch;
-import com.jcraft.jsch.JSchException;
-import com.jcraft.jsch.Session;
-import com.jcraft.jsch.UserInfo;
-import com.jcraft.jsch.Proxy;
-import com.jcraft.jsch.ProxyHTTP;
-import com.jcraft.jsch.ProxySOCKS5;
+import com.jcraft.jsch.*;
 import org.apache.commons.vfs.FileSystemException;
 import org.apache.commons.vfs.FileSystemOptions;
 import org.apache.commons.vfs.util.Os;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 
 import java.io.File;
 import java.util.Properties;
@@ -40,6 +36,8 @@
 {
     private static final String SSH_DIR_NAME = ".ssh";
 
+    private static final Log log = LogFactory.getLog(SftpClientFactory.class);
+
     private SftpClientFactory()
     {
     }
@@ -57,6 +55,7 @@
     public static Session createConnection(String hostname, int port, char[] username, char[] password,
                                            FileSystemOptions fileSystemOptions) throws FileSystemException
     {
+        JSch.setLogger(new JSchLogger());
         JSch jsch = new JSch();
 
         File sshDir = null;
@@ -287,4 +286,40 @@
         }
         return new File("");
     }
+
+    public static class JSchLogger implements Logger {
+        public boolean isEnabled(int level) {
+            switch (level) {
+                case FATAL:
+                    return log.isFatalEnabled();
+                case ERROR:
+                    return log.isErrorEnabled();
+                case WARN:
+                    return log.isWarnEnabled();
+                case INFO:
+                    return log.isInfoEnabled();
+                default:
+                    return log.isDebugEnabled();
+            }
+        }
+
+        public void log(int level, String message) {
+            switch (level) {
+                case FATAL:
+                    log.fatal("[JSCH] " + message);
+                    break;
+                case ERROR:
+                    log.error("[JSCH] " + message);
+                    break;
+                case WARN:
+                    log.warn("[JSCH] " + message);
+                    break;
+                case INFO:
+                    log.info("[JSCH] " + message);
+                    break;
+                default:
+                    log.debug("[JSCH] " + message);
+            }
+        }
+    }
 }