diff options
author | Tschaen, Brendan <ctschaen@att.com> | 2018-11-15 10:31:53 -0500 |
---|---|---|
committer | Tschaen, Brendan <ctschaen@att.com> | 2018-11-15 10:32:38 -0500 |
commit | a1f03a639a2ba38ec5c19e96c3c9d703fa048a8f (patch) | |
tree | cfa2b706104c5a05cd67ce88568296876b7d3a49 /src/main/java/org/onap/music/main/CronJobManager.java | |
parent | 7addd52dc73e6571028ca7f6a018e75ec1c9b0ca (diff) |
Revert "music core implemented as a service"
This reverts commit 7addd52dc73e6571028ca7f6a018e75ec1c9b0ca.
Change-Id: I0875ce10521363b8e17eb6cd2cf9d8848e572bea
Issue-ID: MUSIC-189
Signed-off-by: Tschaen, Brendan <ctschaen@att.com>
Diffstat (limited to 'src/main/java/org/onap/music/main/CronJobManager.java')
-rw-r--r-- | src/main/java/org/onap/music/main/CronJobManager.java | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/src/main/java/org/onap/music/main/CronJobManager.java b/src/main/java/org/onap/music/main/CronJobManager.java index 2ed1a97e..5b7a8de4 100644 --- a/src/main/java/org/onap/music/main/CronJobManager.java +++ b/src/main/java/org/onap/music/main/CronJobManager.java @@ -34,8 +34,6 @@ import javax.servlet.annotation.WebListener; import org.onap.music.datastore.PreparedQueryObject; import org.onap.music.exceptions.MusicLockingException; import org.onap.music.exceptions.MusicServiceException; -import org.onap.music.service.MusicCoreService; -import org.onap.music.service.impl.MusicCassaCore; import com.datastax.driver.core.ResultSet; import com.datastax.driver.core.Row; @@ -44,7 +42,6 @@ import com.datastax.driver.core.Row; public class CronJobManager implements ServletContextListener { private ScheduledExecutorService scheduler; - private static MusicCoreService musicCore = MusicCassaCore.getInstance(); @Override public void contextInitialized(ServletContextEvent event) { @@ -54,7 +51,7 @@ public class CronJobManager implements ServletContextListener { String consistency = MusicUtil.EVENTUAL; pQuery.appendQueryString("CREATE TABLE IF NOT EXISTS admin.locks ( lock_id text PRIMARY KEY, ctime text)"); try { - ResultType result = musicCore.nonKeyRelatedPut(pQuery, consistency); + ResultType result = MusicCore.nonKeyRelatedPut(pQuery, consistency); } catch (MusicServiceException e1) { e1.printStackTrace(); } @@ -63,7 +60,7 @@ public class CronJobManager implements ServletContextListener { pQuery.appendQueryString( "select * from admin.locks"); try { - ResultSet rs = musicCore.get(pQuery); + ResultSet rs = MusicCore.get(pQuery); Iterator<Row> it = rs.iterator(); StringBuilder deleteKeys = new StringBuilder(); Boolean expiredKeys = false; @@ -74,7 +71,7 @@ public class CronJobManager implements ServletContextListener { if(System.currentTimeMillis() >= ctime + 24 * 60 * 60 * 1000) { expiredKeys = true; String new_id = id.substring(1); - musicCore.deleteLock(new_id); + MusicCore.deleteLock(new_id); deleteKeys.append(id).append(","); } else { @@ -106,7 +103,7 @@ public class CronJobManager implements ServletContextListener { expiredKeys = true; String id = pair.getKey(); deleteKeys.append("'").append(id).append("'").append(","); - musicCore.deleteLock(id.substring(1)); + MusicCore.deleteLock(id.substring(1)); MusicUtil.zkNodeMap.remove(id); } catch (MusicLockingException e) { @@ -132,7 +129,7 @@ public class CronJobManager implements ServletContextListener { pQuery.appendQueryString( "DELETE FROM admin.locks WHERE lock_id IN ("+deleteKeys+")"); try { - musicCore.nonKeyRelatedPut(pQuery, "eventual"); + MusicCore.nonKeyRelatedPut(pQuery, "eventual"); } catch (Exception e) { e.printStackTrace(); } |