diff options
Diffstat (limited to 'components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java')
| -rw-r--r-- | components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java index 3be5be6e..5c544d6c 100644 --- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java +++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java @@ -62,8 +62,15 @@ public class DmaapService { @PreDestroy public void cleanUp() throws InterruptedException { - if (zk != null) { - zk.close(); + config.getShutdownLock().readLock().lock(); + + try { + if (zk != null) { + log.info("cleanUp() called, close zk."); + zk.close(); + } + } finally { + config.getShutdownLock().readLock().unlock(); } } |