No data is lost when program is killed 68/90268/2
authorGuobiao Mo <guobiaomo@chinamobile.com>
Thu, 20 Jun 2019 22:30:44 +0000 (15:30 -0700)
committerYan Yang <yangyanyj@chinamobile.com>
Fri, 21 Jun 2019 05:12:48 +0000 (05:12 +0000)
commit7d3fb8e0a193c1471fcde17ddbe855b5ac1ebd70
tree6f40c532cefad95c8a42981283661a3bd6e84f6a
parent369eb4e1b30be855a4c4224d6c0d53ca97423eaf
No data is lost when program is killed

When the program is killed by unix 'kill' or crtl+c,
program should exits gracefully after all data is saved to DBs.

Issue-ID: DCAEGEN2-1633

Change-Id: Ic134440be507faa44d04434eeaea1035ce7d63f0
Signed-off-by: Guobiao Mo <guobiaomo@chinamobile.com>
14 files changed:
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/config/ApplicationConfiguration.java
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/FeederController.java
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/CouchbaseService.java
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/ElasticsearchService.java
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/HdfsService.java
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/MongodbService.java
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/PullService.java
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/TopicConfigPollingService.java
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/util/JsonUtil.java
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/CouchbaseServiceTest.java
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/DmaapServiceTest.java
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/MongodbServiceTest.java
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/TopicServiceTest.java