diff options
Diffstat (limited to 'dcae_dmaapbc_client/src/test')
-rw-r--r-- | dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java | 159 |
1 files changed, 0 insertions, 159 deletions
diff --git a/dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java b/dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java deleted file mode 100644 index e90c7b8..0000000 --- a/dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java +++ /dev/null @@ -1,159 +0,0 @@ -package org.openecomp.dcae.dmaapbc; - -import java.util.List; - -import org.junit.Test; -import org.openecomp.dcae.dmaap.bcapi.client.DmaapBcRestClient; -import org.openecomp.dcae.dmaap.bcapi.client.HttpStatusAndResponse; -import org.openecomp.dcae.dmaapbc.model.DmaapObject; -import org.openecomp.dcae.dmaapbc.model.Feed; -import org.openecomp.dcae.dmaapbc.model.Topic; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -public class TestDmaapBcRestClient { - - private static Logger logger = LoggerFactory.getLogger(TestDmaapBcRestClient.class); - - /** - * Exercises some of the DMaaP Bus Controller client's functionality. - */ - @Test - public void test() throws Exception { - DmaapBcRestClient client = new DmaapBcRestClient("https://host:8443/webapi/", - "host", "MechIdPassword"); - - // This may help when in a hurry, but it's dangerous. - // client.setFailOnUnknownProperties(false); - - DmaapObject dmaap = client.getDmaap(); - if (dmaap == null) - logger.warn("Failed to get DMAAP"); - else - logger.info("DMAAP is " + dmaap.toString()); - - List<DmaapObject> locs = client.getDcaeLocations(); - if (locs == null) { - logger.warn("Failed to get DCAE locations"); - } else { - logger.info("Loc count is " + locs.size()); - for (DmaapObject loc : locs) - logger.info("Location is: " + loc.toString()); - } - - List<DmaapObject> nodes = client.getDRNodes(); - if (nodes == null) { - logger.warn("Failed to get nodes"); - } else { - logger.info("node count is " + nodes.size()); - for (DmaapObject node : nodes) - logger.info("Nodeis: " + node.toString()); - } - - List<DmaapObject> drPubs = client.getDRPubs(); - if (drPubs == null) { - logger.warn("Failed to get DR pubs"); - } else { - logger.info("DR_Pub count is " + drPubs.size()); - for (DmaapObject pub : drPubs) - logger.info("DR_Pub is: " + pub.toString()); - } - List<DmaapObject> drSubs = client.getDRSubs(); - if (drSubs == null) { - logger.warn("Failed to get DR subs"); - } else { - logger.info("DR_Sub count is " + drSubs.size()); - for (DmaapObject sub : drSubs) - logger.info("DR_Sub is: " + sub.toString()); - } - - List<DmaapObject> feeds = client.getFeeds(); - if (feeds == null) { - logger.warn("Failed to get feeds"); - } else { - logger.info("Feed count is " + feeds.size()); - for (DmaapObject feed : feeds) - logger.info("Feed is: " + feed.toString()); - } - List<DmaapObject> topics = client.getTopics(); - if (topics == null) { - logger.warn("Failed to get topics"); - } else { - logger.info("Topic count is " + topics.size()); - for (DmaapObject topic : topics) - logger.info("Topic is: " + topic.toString()); - } - List<DmaapObject> clients = client.getMRClients(); - if (clients == null) { - logger.warn("Failed to get MR clients"); - } else { - logger.info("MR client count is " + clients.size()); - for (DmaapObject mrc : clients) - logger.info("MR client is: " + mrc.toString()); - } - List<DmaapObject> clusters = client.getMRClusters(); - if (clusters == null) { - logger.warn("Failed to get MR clusters"); - } else { - logger.info("MR cluster count is " + clusters.size()); - for (DmaapObject mrc : clusters) - logger.info("MR cluster is: " + mrc.toString()); - } - - // Create and delete feed - - Feed feed = (Feed) feeds.get(0); - final String feedId = "987654321"; - final String feedName = "TestFeed1234567890"; - final String feedUrl = "http://host.com/foo/bar"; - feed.setFeedId(feedId); - feed.setFeedName(feedName); - feed.setPublishURL(feedUrl); - HttpStatusAndResponse<Object> addFeedResp = client.postFeed(feed); - if (addFeedResp.getStatusCode() == 200) - logger.info("add feed succeeded, response is " + addFeedResp); - else - logger.error("add feed failed, response is " + addFeedResp); - - DmaapObject getFeedResp = client.getFeed(feedId); - logger.info("get feed response is " + getFeedResp); - HttpStatusAndResponse<Object> delFeedResp = client.deleteFeed(feedId); - if (delFeedResp.getStatusCode() == 200) - logger.info("delete feed succeeded, response is " + delFeedResp); - else - logger.error("delete feed failed, response is " + delFeedResp); - - // Attempt to create empty feed should fail -- but does not - // Feed emptyFeed = new Feed(); - // HttpStatusAndResponse<Object> addEmptyFeedResp = - // client.postFeed(emptyFeed); - // if (addEmptyFeedResp.getStatusCode() == 200) - // logger.info("add feed succeeded, response is " + addFeedResp); - // else - // logger.error("add feed failed, response is " + addFeedResp); - - // Create and delete topic - - Topic topic = new Topic(); - final String fqtn = "host"; - topic.setFqtn(fqtn); - HttpStatusAndResponse<Object> createTopicResp = client.postTopic(topic); - logger.info("create topic response is " + createTopicResp); - DmaapObject getTopicResp = client.getTopic(fqtn); - logger.info("get topic response is " + getTopicResp); - HttpStatusAndResponse<Object> delTopic = client.deleteTopic(fqtn); - if (delTopic.getStatusCode() == 200) - logger.info("del topic succeeded, response is " + delTopic); - else - logger.error("del topic failed, response is " + delTopic); - HttpStatusAndResponse<Object> delTopicMissing = client.deleteTopic(fqtn); - if (delTopicMissing.getStatusCode() == 204) - logger.info("del of missing topic succeeded, response is " + delTopicMissing); - else - logger.error("del of missing topic failed, response is " + delTopic); - - logger.info("ends"); - - } - -} |