X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=music-core%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fmusic%2Flockingservice%2Fcassandra%2FLockCleanUpDaemon.java;h=623a07c752e8b6c830f9ad2841ccae5938285c4e;hb=d2044d7b9b30d922d2717b1952075c26bce91f04;hp=492a48f0b07ca61d39bc47b401aec05b8f669998;hpb=3e7717442eceb670bfa69ddb27c9abe68e99a920;p=music.git

diff --git a/music-core/src/main/java/org/onap/music/lockingservice/cassandra/LockCleanUpDaemon.java b/music-core/src/main/java/org/onap/music/lockingservice/cassandra/LockCleanUpDaemon.java
index 492a48f0..623a07c7 100644
--- a/music-core/src/main/java/org/onap/music/lockingservice/cassandra/LockCleanUpDaemon.java
+++ b/music-core/src/main/java/org/onap/music/lockingservice/cassandra/LockCleanUpDaemon.java
@@ -23,12 +23,10 @@
 package org.onap.music.lockingservice.cassandra;
 
 import java.util.HashSet;
-import java.util.List;
 import java.util.Set;
 import org.onap.music.datastore.MusicDataStoreHandle;
 import org.onap.music.datastore.PreparedQueryObject;
 import org.onap.music.eelf.logging.EELFLoggerDelegate;
-import org.onap.music.exceptions.MusicQueryException;
 import org.onap.music.exceptions.MusicServiceException;
 import org.onap.music.main.MusicCore;
 import org.onap.music.main.MusicUtil;
@@ -58,7 +56,8 @@ public class LockCleanUpDaemon extends Thread {
             try {
                 Thread.sleep(MusicUtil.getLockDaemonSleepTimeMs());
             } catch (InterruptedException e) {
-                e.printStackTrace();
+                logger.warn(EELFLoggerDelegate.applicationLogger, "Interrupted exception", e);
+
             }
         }
     }
@@ -110,12 +109,14 @@ public class LockCleanUpDaemon extends Thread {
     
     
     private void deleteLockIfStale(String lockTable, Row lock) throws MusicServiceException {
-        if (lock.isNull("createtime") && lock.isNull("acquiretime")) {
+        final String CREATETIME="createtime";
+        final String ACQUIRETIME="acquiretime";
+        if (lock.isNull(CREATETIME) && lock.isNull("acquiretime")) {
             return;
         }
 
-        long createTime = lock.isNull("createtime") ? 0 : Long.parseLong(lock.getString("createtime"));
-        long acquireTime = lock.isNull("acquiretime") ? 0 : Long.parseLong(lock.getString("acquiretime"));
+        long createTime = lock.isNull(CREATETIME) ? 0 : Long.parseLong(lock.getString(CREATETIME));
+        long acquireTime = lock.isNull(ACQUIRETIME) ? 0 : Long.parseLong(lock.getString(ACQUIRETIME));
         long row_access_time = Math.max(createTime, acquireTime);
         if (System.currentTimeMillis() > row_access_time + MusicUtil.getDefaultLockLeasePeriod()) {
             logger.info(EELFLoggerDelegate.applicationLogger, "Stale lock detected and being removed: " + lock);