git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube...

diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/NEXIO2TransferToStep.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/NEXIO2TransferToStep.java
index 20c81a6840ae9f1d3a7d2eeab00bda037f727671..8677f166a7cb95c6860ce4ddfbe4cbe87e13eb4f 100644 (file)
--- a/server/user.jobengine.executors/src/user/jobengine/server/steps/NEXIO2TransferToStep.java
+++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/NEXIO2TransferToStep.java
@@ -1,53 +1,44 @@
 package user.jobengine.server.steps;\r
 \r
-import java.util.Arrays;\r
-import java.util.List;\r
-\r
-import org.apache.commons.net.ftp.FTPClient;\r
 import org.apache.logging.log4j.LogManager;\r
 import org.apache.logging.log4j.Logger;\r
 \r
 import user.commons.StoreUri;\r
-import user.commons.remotestore.FtpDirectoryLister;\r
 \r
 public class NEXIO2TransferToStep extends TransferStep {\r
        private static final Logger logger = LogManager.getLogger();\r
 \r
        @Override\r
        @StepEntry\r
-       public Object[] execute(StoreUri sourceStoreUri, String sourceFileName, StoreUri targetStoreUri, String targetFileName) throws Exception {\r
-               //              try {\r
-               //                      String title = targetFileName;\r
-               //                      if (title.contains("."))\r
-               //                              title = title.substring(0, title.lastIndexOf("."));\r
-               //                      RemoteFile remoteFile = targetStoreUri.getFileWithContent(title + ".xml");\r
-               //                      if (remoteFile != null && remoteFile.getContent() != null) {\r
-               //                              logger.info("File already exists on NEXIO2 {}", targetFileName);\r
-               //                              return null;\r
-               //                      }\r
-               //              } catch (Exception e) {\r
-               //                      logger.error(e.getMessage());\r
-               //              } finally {\r
-               //                      targetStoreUri.cleanUp();\r
-               //              }\r
-/*\r
-               try {\r
-                       FTPClient client = ((FtpDirectoryLister) targetStoreUri.getLister()).connect();\r
-                       logger.info(getMarker(), "Reading target file list");\r
-                       List<String> fileNames = Arrays.asList(client.listNames());\r
-                       logger.info(getMarker(), "Target file list reading completed, mediabase size is {}", fileNames.size());\r
-                       String title = targetFileName.replace(".mxf", ".lxf");\r
-                       boolean contains = fileNames.contains(title);\r
-                       if (contains) {\r
-                               logger.info(getMarker(), "File already exists {} on {}", title, getManager().getStore(targetStoreUri.getStoreId()).getName());\r
-                               return null;\r
-                       }\r
-               } catch (Exception e) {\r
-                       logger.catching(e);\r
-               } finally {\r
-                       targetStoreUri.cleanUp();\r
-               }\r
-*/\r
+       public Object[] execute(StoreUri sourceStoreUri, String sourceFileName, StoreUri targetStoreUri,\r
+                       String targetFileName) throws Exception {\r
+               // try {\r
+               // String title = targetFileName;\r
+               // if (title.contains("."))\r
+               // title = title.substring(0, title.lastIndexOf("."));\r
+               // RemoteFile remoteFile = targetStoreUri.getFileWithContent(title + ".xml");\r
+               // if (remoteFile != null && remoteFile.getContent() != null) {\r
+               // logger.info("File already exists on NEXIO2 {}", targetFileName);\r
+               // return null;\r
+               // }\r
+               // } catch (Exception e) {\r
+               // logger.error(e.getMessage());\r
+               // } finally {\r
+               // targetStoreUri.cleanUp();\r
+               // }\r
+               /*\r
+                * try { FTPClient client = ((FtpDirectoryLister)\r
+                * targetStoreUri.getLister()).connect(); logger.info(getMarker(),\r
+                * "Reading target file list"); List<String> fileNames =\r
+                * Arrays.asList(client.listNames()); logger.info(getMarker(),\r
+                * "Target file list reading completed, mediabase size is {}",\r
+                * fileNames.size()); String title = targetFileName.replace(".mxf", ".lxf");\r
+                * boolean contains = fileNames.contains(title); if (contains) {\r
+                * logger.info(getMarker(), "File already exists {} on {}", title,\r
+                * getManager().getStore(targetStoreUri.getStoreId()).getName()); return null; }\r
+                * } catch (Exception e) { logger.catching(e); } finally {\r
+                * targetStoreUri.cleanUp(); }\r
+                */\r
                return super.execute(sourceStoreUri, sourceFileName, targetStoreUri, targetFileName);\r
        }\r
 }\r