X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fservice%2FMMRestService.java;fp=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fservice%2FMMRestService.java;h=4a2c90846b2d1d4f89342710899d4fa0160bee80;hb=8cd116bf2295fda6adbc41f87ae4d94fac572fb6;hp=e271dce69f8fd5332d74da7863748a93861d7900;hpb=3884959f0bb9e6d0187606aa4342a80f366ca324;p=dmaap%2Fmessagerouter%2Fmessageservice.git

diff --git a/src/main/java/org/onap/dmaap/service/MMRestService.java b/src/main/java/org/onap/dmaap/service/MMRestService.java
index e271dce..4a2c908 100644
--- a/src/main/java/org/onap/dmaap/service/MMRestService.java
+++ b/src/main/java/org/onap/dmaap/service/MMRestService.java
@@ -1362,47 +1362,27 @@ public class MMRestService {
 		}
 	}
 
-	private String getWhitelistByNamespace(String originalWhitelist, String namespace) {
 
-		String whitelist = null;
-		List<String> resultList = new ArrayList<>();
-		List<String> whitelistList = new ArrayList<>();
-		whitelistList = Arrays.asList(originalWhitelist.split(","));
-
-		for (String topic : whitelistList) {
-			if (StringUtils.isNotBlank(originalWhitelist) && getNamespace(topic).equals(namespace)) {
-				resultList.add(topic);
-			}
-		}
-		if (!resultList.isEmpty()) {
-			whitelist = StringUtils.join(resultList, ",");
-		}
-
-		return whitelist;
-	}
-
-	private JSONArray getListMirrorMaker(String msgFrmSubscribe, String randomStr) {
-		JSONObject jsonObj;
-		JSONArray jsonArray;
+	public JSONArray getListMirrorMaker(String msgFrmSubscribe, String randomStr) {
+		JSONObject jsonObj = new JSONObject();
+		JSONArray jsonArray = new JSONArray();
 		JSONArray listMirrorMaker = new JSONArray();
-
+		
 		msgFrmSubscribe = removeExtraChar(msgFrmSubscribe);
 		jsonArray = new JSONArray(msgFrmSubscribe);
-
+		jsonObj = jsonArray.getJSONObject(0);
+		
 		for (int i = 0; i < jsonArray.length(); i++) {
 			jsonObj = jsonArray.getJSONObject(i);
-
-			JSONObject obj = new JSONObject();
-			if (jsonObj.has(MESSAGE)) {
-				obj = jsonObj.getJSONObject(MESSAGE);
-			}
-			if (obj.has("messageID") && obj.get("messageID").equals(randomStr) && obj.has(LISTMIRRORMAKER)) {
-				listMirrorMaker = obj.getJSONArray(LISTMIRRORMAKER);
+			
+			if (jsonObj.has("messageID") && jsonObj.get("messageID").equals(randomStr) && jsonObj.has("listMirrorMaker")) {
+				listMirrorMaker = jsonObj.getJSONArray("listMirrorMaker");
 				break;
 			}
 		}
-		return listMirrorMaker;
+		return listMirrorMaker;		
 	}
+	
 
 	public JSONObject validateMMExists(DMaaPContext ctx, String name) throws Exception {
 		// Create a listAllMirrorMaker Json object