summaryrefslogtreecommitdiffstats
path: root/dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java
diff options
context:
space:
mode:
Diffstat (limited to 'dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java')
-rw-r--r--dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java159
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");
-
- }
-
-}