Commit 02a485f1 authored by Spiros Koulouzis's avatar Spiros Koulouzis

removed move files

parent 622f4480
...@@ -372,14 +372,13 @@ public class Consumer extends DefaultConsumer { ...@@ -372,14 +372,13 @@ public class Consumer extends DefaultConsumer {
File topologyFile = MessageParsing.getTopologies(parameters, tempInputDirPath, 0).get(0); File topologyFile = MessageParsing.getTopologies(parameters, tempInputDirPath, 0).get(0);
File mainTopologyFile = new File(tempInputDirPath + "topology_main.yml"); File mainTopologyFile = new File(tempInputDirPath + "topology_main.yml");
FileUtils.moveFile(topologyFile, mainTopologyFile);
String topTopologyLoadingPath = mainTopologyFile.getAbsolutePath(); String topTopologyLoadingPath = mainTopologyFile.getAbsolutePath();
List<File> topologyFiles = MessageParsing.getTopologies(parameters, tempInputDirPath, 1); List<File> topologyFiles = MessageParsing.getTopologies(parameters, tempInputDirPath, 1);
for (File lowLevelTopologyFile : topologyFiles) { // for (File lowLevelTopologyFile : topologyFiles) {
File secondaryTopologyFile = new File(tempInputDirPath + File.separator + lowLevelTopologyFile.getName() + ".yml"); // File secondaryTopologyFile = new File(tempInputDirPath + File.separator + lowLevelTopologyFile.getName() + ".yml");
FileUtils.moveFile(lowLevelTopologyFile, secondaryTopologyFile); // FileUtils.moveFile(lowLevelTopologyFile, secondaryTopologyFile);
} // }
File clusterDir = new File(tempInputDirPath + File.separator + "clusterKeyPair"); File clusterDir = new File(tempInputDirPath + File.separator + "clusterKeyPair");
clusterDir.mkdir(); clusterDir.mkdir();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment