Code Review / dcaegen2 / collectors / datafile.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 4bd2813) | patch
Local filename updated, stability issues 97/82597/6
authorPatrikBuhr <patrik.buhr@est.tech>
Fri, 22 Mar 2019 14:29:29 +0000 (14:29 +0000)
committerPatrikBuhr <patrik.buhr@est.tech>
Fri, 22 Mar 2019 14:29:29 +0000 (14:29 +0000)
commite1a66425d3ba1df5ae2a8f2b99168707e08b655a
treebdfcbdbe4a3dd7286a562f974dec61691e216848tree | snapshot
parent4bd281390ed24b278846775c1157f82db81fddbecommit | diff
Local filename updated, stability issues

The local filename is changed so it contains PNF name
instead of the PNF IP address.

The paralellism is restricted to 100 worker threads in order to
solve problems with too many open file descriptors and out of memory.

Logging is improved.

Change-Id: I24ce2e23020cc253a3c7bebac1ab5cf703b5b144
Issue-ID: DCAEGEN2-1118
Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
23 files changed:
datafile-app-server/config/application.yaml diff | blob | history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/AppConfig.java diff | blob | history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/SchedulerConfig.java diff | blob | history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/exceptions/DmaapNotFoundException.java [deleted file] blob | history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/model/FileData.java diff | blob | history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/model/FileReadyMessage.java diff | blob | history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/service/JsonMessageParser.java diff | blob | history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/DMaaPMessageConsumerTask.java diff | blob | history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/DataRouterPublisher.java diff | blob | history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/FileCollector.java diff | blob | history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/PublishedChecker.java diff | blob | history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/ScheduledTasks.java diff | blob | history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/model/FileDataTest.java diff | blob | history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/service/JsonMessageParserTest.java diff | blob | history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/tasks/DMaaPMessageConsumerTaskImplTest.java diff | blob | history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/tasks/DataRouterPublisherTest.java diff | blob | history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/tasks/FileCollectorTest.java diff | blob | history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/tasks/ScheduledTasksTest.java diff | blob | history
datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FileCollectClient.java diff | blob | history
datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpsClient.java diff | blob | history
datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/SftpClient.java diff | blob | history
datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/service/producer/DmaapProducerReactiveHttpClient.java diff | blob | history
datafile-dmaap-client/src/test/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpsClientTest.java diff | blob | history
Data File collector