Code Review
/
nonrtric
/
plt
/
ranpm.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Some tidying up
[nonrtric/plt/ranpm.git]
/
datafilecollector
/
src
/
main
/
java
/
org
/
onap
/
dcaegen2
/
collectors
/
datafile
/
tasks
/
FileCollector.java
diff --git
a/datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/FileCollector.java
b/datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/FileCollector.java
index
b6c07e5
..
2b3ce53
100644
(file)
--- a/
datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/FileCollector.java
+++ b/
datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/FileCollector.java
@@
-17,12
+17,12
@@
package org.onap.dcaegen2.collectors.datafile.tasks;
package org.onap.dcaegen2.collectors.datafile.tasks;
+import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.time.Duration;
import java.util.Optional;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.time.Duration;
import java.util.Optional;
-import org.apache.commons.io.FileUtils;
import org.onap.dcaegen2.collectors.datafile.commons.FileCollectClient;
import org.onap.dcaegen2.collectors.datafile.commons.Scheme;
import org.onap.dcaegen2.collectors.datafile.configuration.AppConfig;
import org.onap.dcaegen2.collectors.datafile.commons.FileCollectClient;
import org.onap.dcaegen2.collectors.datafile.commons.Scheme;
import org.onap.dcaegen2.collectors.datafile.configuration.AppConfig;
@@
-103,7
+103,7
@@
public class FileCollector {
try (FileCollectClient currentClient = createClient(fileData)) {
currentClient.open();
try (FileCollectClient currentClient = createClient(fileData)) {
currentClient.open();
- File
Utils.forceMkdirParent(localFile.toFile
());
+ File
s.createDirectories(localFile.getParent
());
currentClient.collectFile(remoteFile, localFile);
counters.incNoOfCollectedFiles();
return Mono.just(Optional.of(createFilePublishInformation(fileData)));
currentClient.collectFile(remoteFile, localFile);
counters.incNoOfCollectedFiles();
return Mono.just(Optional.of(createFilePublishInformation(fileData)));