diff options
author | Vijay Venkatesh Kumar <vv770d@att.com> | 2018-07-19 22:02:53 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@onap.org> | 2018-07-19 22:02:53 +0000 |
commit | d12cd3525284cc41414d8fdae09e2ffbc03a1fbb (patch) | |
tree | db38e32b03abddef146f7d02772c4baa3b1ae673 /src/test/java/org/onap/dcae/vestest/TestingUtilities.java | |
parent | b343343f1efd0df9196b27e9e65b783e5e954112 (diff) | |
parent | 129240ca4c0f10cf4916882f99e91072db048a4c (diff) |
Merge "VES collector application settings provider"
Diffstat (limited to 'src/test/java/org/onap/dcae/vestest/TestingUtilities.java')
-rw-r--r-- | src/test/java/org/onap/dcae/vestest/TestingUtilities.java | 15 |
1 files changed, 14 insertions, 1 deletions
diff --git a/src/test/java/org/onap/dcae/vestest/TestingUtilities.java b/src/test/java/org/onap/dcae/vestest/TestingUtilities.java index 7c7c09dc..eff31f6d 100644 --- a/src/test/java/org/onap/dcae/vestest/TestingUtilities.java +++ b/src/test/java/org/onap/dcae/vestest/TestingUtilities.java @@ -23,6 +23,8 @@ import static java.nio.file.Files.readAllBytes; import com.google.gson.JsonObject; import com.google.gson.JsonParser; +import io.vavr.collection.HashMap; + import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; @@ -30,7 +32,7 @@ import java.nio.file.Paths; /** * @author Pawel Szalapski (pawel.szalapski@nokia.com) */ -final class TestingUtilities { +public final class TestingUtilities { private TestingUtilities() { // utility class, no objects allowed @@ -50,6 +52,17 @@ final class TestingUtilities { }); } + public static HashMap<String, String[]> convertDMaaPStreamsPropertyToMap(String streamIdsProperty) { + java.util.HashMap<String, String[]> domainToStreamIdsMapping = new java.util.HashMap<>(); + String[] topics = streamIdsProperty.split("\\|"); + for (String t : topics) { + String domain = t.split("=")[0]; + String[] streamIds = t.split("=")[1].split(","); + domainToStreamIdsMapping.put(domain, streamIds); + } + return HashMap.ofAll(domainToStreamIdsMapping); + } + private static Path createFile(String path) { return rethrow(() -> Files.createFile(Paths.get(path))); } |