diff options
author | Tschaen, Brendan <ctschaen@att.com> | 2020-01-27 18:02:48 -0500 |
---|---|---|
committer | Tschaen, Brendan <ctschaen@att.com> | 2020-01-27 18:02:48 -0500 |
commit | 19967120639154dcb4ed154113015b7d1ed9b7f1 (patch) | |
tree | 65b7e3d4424f0d82ebf03a135d7e4471c29e03b6 /music-core/src/main/java/org/onap/music/service/impl/MusicCassaCore.java | |
parent | a0a52fadf838954bf4e133d8dd94f5114ddc4ac4 (diff) |
Further MusicCassaCore Testing
Change-Id: I6314a6ea15e3787b840050deb04190e1928c20e2
Issue-ID: MUSIC-521
Signed-off-by: Tschaen, Brendan <ctschaen@att.com>
Diffstat (limited to 'music-core/src/main/java/org/onap/music/service/impl/MusicCassaCore.java')
-rw-r--r-- | music-core/src/main/java/org/onap/music/service/impl/MusicCassaCore.java | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/music-core/src/main/java/org/onap/music/service/impl/MusicCassaCore.java b/music-core/src/main/java/org/onap/music/service/impl/MusicCassaCore.java index 63f2d14c..1f3f4a32 100644 --- a/music-core/src/main/java/org/onap/music/service/impl/MusicCassaCore.java +++ b/music-core/src/main/java/org/onap/music/service/impl/MusicCassaCore.java @@ -84,7 +84,8 @@ public class MusicCassaCore implements MusicCoreService { return mLockHandle; } - public static void setmLockHandle(CassaLockStore mLockHandle) { + //for unit testing purposes + static void setmLockHandle(CassaLockStore mLockHandle) { MusicCassaCore.mLockHandle = mLockHandle; } @@ -348,7 +349,6 @@ public class MusicCassaCore implements MusicCoreService { * @return Boolean Indicates success or failure * @throws MusicServiceException * - * */ public ResultType createTable(String keyspace, String table, PreparedQueryObject tableQueryObject, String consistency) throws MusicServiceException { @@ -357,9 +357,9 @@ public class MusicCassaCore implements MusicCoreService { try { // create shadow locking table result = getLockingServiceHandle().createLockQueue(keyspace, table); - if (result == false) + if (result == false) { return ResultType.FAILURE; - + } result = false; // create table to track unsynced_keys @@ -370,8 +370,11 @@ public class MusicCassaCore implements MusicCoreService { PreparedQueryObject queryObject = new PreparedQueryObject(); queryObject.appendQueryString(tabQuery); - result = false; result = MusicDataStoreHandle.getDSHandle().executePut(queryObject, "eventual"); + if (result == false) { + return ResultType.FAILURE; + } + result = false; // create actual table result = MusicDataStoreHandle.getDSHandle().executePut(tableQueryObject, consistency); |