[jboss-svn-commits] JBL Code SVN: r7838 - in labs/jbossesb/workspace/b_georges/product/core: listeners/src/org/jboss/soa/esb/listeners/gateway rosetta/src/org/jboss/soa/esb/addressing/eprs rosetta/src/org/jboss/soa/esb/util

[jboss-svn-commits at lists.jboss.org]

Author: b_georges
Date: 2006-11-26 11:54:24 -0500 (Sun, 26 Nov 2006)
New Revision: 7838

Added:
   labs/jbossesb/workspace/b_georges/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/FTPGatewayListener.java
   labs/jbossesb/workspace/b_georges/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/SecureFTPEpr.java
Modified:
   labs/jbossesb/workspace/b_georges/product/core/rosetta/src/org/jboss/soa/esb/util/RemoteFileSystemFactory.java
Log:
Applying input from Berlin's Workshop with Esteban.

Added: labs/jbossesb/workspace/b_georges/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/FTPGatewayListener.java
===================================================================
--- labs/jbossesb/workspace/b_georges/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/FTPGatewayListener.java	2006-11-26 15:27:23 UTC (rev 7837)
+++ labs/jbossesb/workspace/b_georges/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/FTPGatewayListener.java	2006-11-26 16:54:24 UTC (rev 7838)
@@ -0,0 +1,54 @@
+/*
+ * FTPGatewayListener.java
+ *
+ * Created on November 26, 2006, 6:34 PM
+ *
+ */
+
+package org.jboss.soa.esb.listeners.gateway;
+
+import java.io.File;
+import java.io.FileFilter;
+import java.lang.reflect.Method;
+import java.util.Collection;
+
+import org.apache.log4j.Logger;
+
+import org.jboss.soa.esb.addressing.EPR;
+import org.jboss.soa.esb.couriers.Courier;
+import org.jboss.soa.esb.helpers.ConfigTree;
+
+/**
+ *
+ * @author b_georges
+ */
+public class FTPGatewayListener extends FileGatewayListener {
+    protected final static Logger _logger = Logger.getLogger(FTPGatewayListener.class);
+    
+    protected ConfigTree 		_config;
+    protected GatewayListenerController _controller;
+    protected long 			_sleepBetweenPolls;   //  milliseconds
+    
+    protected String			_serviceCategory, _serviceName;
+    protected String			_targetServiceCategory ,_targetServiceName;
+    protected EPR			_myEpr;
+    protected Collection<EPR>           _targetEprs;
+    
+    protected String			_composerName;
+    protected Class 			_composerClass;
+    protected Object			_composer;
+    protected Method			_processMethod;
+    
+    protected Courier			_courier;
+    
+    protected boolean			_deleteAfterOK;
+    protected File			_inputDirectory, _errorDirectory, _postProcessDirectory;
+    protected String			_inputSuffix, _postProcessSuffix, _workingSuffix, _errorSuffix;
+    protected FileFilter		_fileFilter;
+    
+    /** Creates a new instance of FTPGatewayListener */
+    public FTPGatewayListener(GatewayListenerController commandListener, ConfigTree config) throws Exception {
+        super(commandListener,config);
+    }
+    
+}

Added: labs/jbossesb/workspace/b_georges/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/SecureFTPEpr.java
===================================================================
--- labs/jbossesb/workspace/b_georges/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/SecureFTPEpr.java	2006-11-26 15:27:23 UTC (rev 7837)
+++ labs/jbossesb/workspace/b_georges/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/SecureFTPEpr.java	2006-11-26 16:54:24 UTC (rev 7838)
@@ -0,0 +1,44 @@
+/*
+ * SecureFTPEpr.java
+ *
+ * Created on November 26, 2006, 5:58 PM
+ *
+ */
+
+package org.jboss.soa.esb.addressing.eprs;
+
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.net.URL;
+import org.jboss.soa.esb.addressing.EPR;
+
+/**
+ *
+ * @author b_georges
+ */
+public class SecureFTPEpr extends FTPEpr 
+{
+    public static final String CLIENT_AUTH_ENABLE_TAG = "clientAuthEnable";
+    public static final String CLIENT_CERT_FILE_TAG = "clientCertFile";
+    public static final String PASSPHRASE_TAG = "passphrase";
+    
+    /** Creates a new instance of SecureFTPEpr */
+    public SecureFTPEpr(EPR epr) 
+    {
+        super(epr);
+        
+        copy(epr);    
+    }
+    
+    public SecureFTPEpr(URL url) throws URISyntaxException 
+    {
+        super(url.toString());
+    }
+    
+    public SecureFTPEpr(String url) throws URISyntaxException 
+    {
+        super(url);
+    }
+    
+    
+}

Modified: labs/jbossesb/workspace/b_georges/product/core/rosetta/src/org/jboss/soa/esb/util/RemoteFileSystemFactory.java
===================================================================
--- labs/jbossesb/workspace/b_georges/product/core/rosetta/src/org/jboss/soa/esb/util/RemoteFileSystemFactory.java	2006-11-26 15:27:23 UTC (rev 7837)
+++ labs/jbossesb/workspace/b_georges/product/core/rosetta/src/org/jboss/soa/esb/util/RemoteFileSystemFactory.java	2006-11-26 16:54:24 UTC (rev 7838)
@@ -27,6 +27,10 @@
 import java.net.URISyntaxException;
 
 import org.jboss.internal.soa.esb.util.EdtFtpImpl;
+import org.jboss.internal.soa.esb.util.SecureFtpImpl;
+import org.jboss.soa.esb.addressing.EPR;
+import org.jboss.soa.esb.addressing.eprs.FTPEpr;
+import org.jboss.soa.esb.addressing.eprs.SecureFTPEpr;
 import org.jboss.soa.esb.helpers.ConfigTree;
 import org.xml.sax.SAXException;
 
@@ -44,6 +48,18 @@
 		return _instance;
 	}
 	
+        public static RemoteFileSystem getRemoteFileSystem(EPR p_oEPR) 
+        {
+            if (p_oEPR instanceof SecureFTPEpr)
+            {
+                return new EdtFtpImpl();
+            }
+            if (p_oEPR instanceof FTPEpr)
+            {
+                return new SecureFtpImpl();
+            }
+        }
+        
 	public static RemoteFileSystem getRemoteFileSystem(ConfigTree p_oP, boolean p_bConnect) throws RemoteFileSystemException
 	{
 		try