diff options
| author |   sa282w <sa282w@att.com> | 2018-06-20 09:44:06 -0400 |
|---|---|---|
| committer | sa282w <sa282w@att.com> | 2018-06-21 10:19:07 -0400 |
| commit | 27666ce5feb0e073f0e7dc43b4f1aa267a6b0975 (patch) | |
| tree | b4eac5f8e3dcfd733ae487cd19d5bbd0785a580a /ecomp-sdk/epsdk-music/src/main/java/org/onap/portalapp/music/service/MusicService.java | |
| parent | 006a26eef7dc5def6e076af9a7c598603369a990 (diff) | |
API Versioning for ECOMP Components in SDK
Issue-ID: PORTAL-263
Included the missing changes for V3 API's and changes from release/2.3.0
to release/2.4.0.
Change-Id: I42173a61ecb6ec29de537c3463d405e1c74d9aaa
Signed-off-by: sa282w <sa282w@att.com>
Diffstat (limited to 'ecomp-sdk/epsdk-music/src/main/java/org/onap/portalapp/music/service/MusicService.java')
| -rw-r--r-- | ecomp-sdk/epsdk-music/src/main/java/org/onap/portalapp/music/service/MusicService.java | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/ecomp-sdk/epsdk-music/src/main/java/org/onap/portalapp/music/service/MusicService.java b/ecomp-sdk/epsdk-music/src/main/java/org/onap/portalapp/music/service/MusicService.java index 801e9c03..3861b2dd 100644 --- a/ecomp-sdk/epsdk-music/src/main/java/org/onap/portalapp/music/service/MusicService.java +++ b/ecomp-sdk/epsdk-music/src/main/java/org/onap/portalapp/music/service/MusicService.java @@ -112,7 +112,7 @@ public class MusicService { } if (isAtomicPut) - result = MusicCore.atomicPut(musicKeySpace, tableName, sessionId, queryObject, null); + result = MusicCore.atomicPutWithDeleteLock(musicKeySpace, tableName, sessionId, queryObject, null); else result = MusicCore.eventualPut(queryObject); logger.debug(EELFLoggerDelegate.debugLogger, "setAttribute: attributeName: " + attributeName @@ -144,7 +144,7 @@ public class MusicService { queryObject.addValue(String.valueOf(session.getMaxInactiveInterval())); queryObject.addValue(session.getId()); if (isAtomicPut) - result = MusicCore.atomicPut(musicKeySpace, musicMetaTable, session.getId(), queryObject, null); + result = MusicCore.atomicPutWithDeleteLock(musicKeySpace, musicMetaTable, session.getId(), queryObject, null); else result = MusicCore.eventualPut(queryObject); logger.debug(EELFLoggerDelegate.debugLogger, @@ -170,7 +170,7 @@ public class MusicService { queryObject.appendQueryString(querySB.toString()); queryObject.addValue(sessionId); if (isAtomicGet) - result = MusicCore.atomicGet(musicKeySpace, musicMetaTable, sessionId, queryObject); + result = MusicCore.atomicGetWithDeleteLock(musicKeySpace, musicMetaTable, sessionId, queryObject); else result = MusicCore.get(queryObject); logger.debug(EELFLoggerDelegate.debugLogger, "getMetaAttribute: with session id: " + sessionId); @@ -226,7 +226,7 @@ public class MusicService { queryObject.appendQueryString(querySB.toString()); if (isAtomicGet) - result = MusicCore.atomicGet(musicKeySpace, tableName, sessionId, queryObject); + result = MusicCore.atomicGetWithDeleteLock(musicKeySpace, tableName, sessionId, queryObject); else result = MusicCore.get(queryObject); return MusicUtil.musicRestResponseDataParsing(result, attributeName); @@ -262,7 +262,7 @@ public class MusicService { tableName = musicMetaTable; queryObject.appendQueryString(querySB.toString()); if (isAtomicPut) - result = MusicCore.atomicPut(musicKeySpace, tableName, sessionId, queryObject, null); + result = MusicCore.atomicPutWithDeleteLock(musicKeySpace, tableName, sessionId, queryObject, null); else result = MusicCore.eventualPut(queryObject); logger.debug(EELFLoggerDelegate.debugLogger, @@ -290,7 +290,7 @@ public class MusicService { queryObject.appendQueryString(querySB.toString()); queryObject.addValue(sessionId); if (isAtomic) - result = MusicCore.atomicPut(musicKeySpace, musicMetaTable, sessionId, queryObject, null); + result = MusicCore.atomicPutWithDeleteLock(musicKeySpace, musicMetaTable, sessionId, queryObject, null); else result = MusicCore.eventualPut(queryObject); logger.debug(EELFLoggerDelegate.debugLogger, "removeSession: " + musicMetaTable + " with session id: " @@ -303,7 +303,7 @@ public class MusicService { queryObject.appendQueryString(querySB.toString()); queryObject.addValue(sessionId); if (isAtomic) - result = MusicCore.atomicPut(musicKeySpace, musicAttrTable, sessionId, queryObject, null); + result = MusicCore.atomicPutWithDeleteLock(musicKeySpace, musicAttrTable, sessionId, queryObject, null); else result = MusicCore.eventualPut(queryObject); @@ -570,7 +570,7 @@ public class MusicService { try{ if (isAtomicGet) - result = MusicCore.atomicGet(musicKeySpace, musicMetaTable, null, queryObject); + result = MusicCore.atomicGetWithDeleteLock(musicKeySpace, musicMetaTable, null, queryObject); else result = MusicCore.get(queryObject); Row row = result.one(); @@ -616,7 +616,7 @@ public class MusicService { queryObject.appendQueryString(querySB.toString()); try{ if (isAtomicPut) - result = MusicCore.atomicPut(musicKeySpace, null, null, queryObject, null); + result = MusicCore.atomicPutWithDeleteLock(musicKeySpace, null, null, queryObject, null); else result = MusicCore.eventualPut(queryObject); }catch(Exception e){ @@ -634,7 +634,7 @@ public class MusicService { queryObject.appendQueryString(querySB.toString()); try{ if (isAtomicPut) - result = MusicCore.atomicPut(musicKeySpace, null, null, queryObject, null); + result = MusicCore.atomicPutWithDeleteLock(musicKeySpace, null, null, queryObject, null); else result = MusicCore.eventualPut(queryObject); }catch(Exception e){ |