X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Forg%2Fonap%2Fdmaap%2Fmr%2Fclient%2Fimpl%2FMRMetaClientTest.java;h=00f127811a331d62754b03b387e641f2dcefe059;hb=72a9ab9e886cdeabc4b43418a7054a5796a0ff55;hp=ea9cab4abbffc947b73b80f190e0bd57b246c712;hpb=78ebc9a64fac6231e3e594200b9335a4c6372ed1;p=dmaap%2Fmessagerouter%2Fdmaapclient.git diff --git a/src/test/java/org/onap/dmaap/mr/client/impl/MRMetaClientTest.java b/src/test/java/org/onap/dmaap/mr/client/impl/MRMetaClientTest.java index ea9cab4..00f1278 100644 --- a/src/test/java/org/onap/dmaap/mr/client/impl/MRMetaClientTest.java +++ b/src/test/java/org/onap/dmaap/mr/client/impl/MRMetaClientTest.java @@ -4,11 +4,13 @@ * ================================================================================ * Copyright © 2017 AT&T Intellectual Property. All rights reserved. * ================================================================================ + * Modifications Copyright © 2021 Orange. + * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -17,110 +19,98 @@ * ============LICENSE_END========================================================= * * ECOMP is a trademark and service mark of AT&T Intellectual Property. - * + * *******************************************************************************/ + package org.onap.dmaap.mr.client.impl; +import com.att.nsa.apiClient.http.HttpException; +import com.att.nsa.apiClient.http.HttpObjectNotFoundException; +import org.junit.Test; +import org.onap.dmaap.mr.client.MRTopicManager.TopicInfo; + import java.io.IOException; import java.util.Collection; import java.util.LinkedList; import java.util.Set; -import org.junit.Before; -import org.junit.Test; import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertTrue; -import com.att.nsa.apiClient.http.HttpException; -import com.att.nsa.apiClient.http.HttpObjectNotFoundException; -import org.onap.dmaap.mr.client.MRTopicManager.TopicInfo; public class MRMetaClientTest { - - //@Rule public WireMockRule wireMock = new WireMockRule(); - - @Before - public void setUp(){/* - wireMock.stubFor(get(urlEqualTo("/topics")) - .willReturn(aResponse().withBody("{\"topics\":[\"topic1\",\"topic2\"]}").withHeader("Content-Type", "application/json"))); - wireMock.stubFor(get(urlEqualTo("/topics/topic1")) - .willReturn(aResponse().withBody("{\"topics\":[\"topic1\",\"topic2\"]}").withHeader("Content-Type", "application/json"))); - wireMock.stubFor(post(urlEqualTo("/topics/create")) - .willReturn(aResponse().withStatus(200))); - */} - - @Test - public void getTopicsTest() - { - final Collection hosts = new LinkedList (); - hosts.add ( "localhost:" +3904 ); - - MRMetaClient c; - try { - c = new MRMetaClient(hosts); - Set setString=c.getTopics(); - } catch (IOException e) { - e.printStackTrace(); - } - assertNotNull(hosts); - - - // assertEquals ("http://localhost:8080/events/" + "topic/cg/cid", url ); - - } - - @Test - public void getTopicMetadataTest() { - final Collection hosts = new LinkedList (); - hosts.add ( "localhost:" + 3904 ); - - final String topic ="topic1"; - - MRMetaClient c; - try { - c = new MRMetaClient(hosts); - TopicInfo topicInfo=c.getTopicMetadata(topic); - } catch (IOException | HttpObjectNotFoundException e) { - e.printStackTrace(); - } - assertNotNull(topic); - - } - - @Test - public void testcreateTopic(){ - final Collection hosts = new LinkedList (); - hosts.add ( "localhost:" + 3904 ); - - MRMetaClient c; - try { - c = new MRMetaClient(hosts); - c.createTopic("topic1", "testTopic", 1, 1); - } catch (IOException | HttpException e) { - e.printStackTrace(); - } - assertNotNull(hosts); - } - @Test - public void testupdateApiKey(){ - final Collection hosts = new LinkedList (); - hosts.add ( "localhost:" + 3904 ); - - MRMetaClient c; - try { - c = new MRMetaClient(hosts); - c.updateCurrentApiKey("test@onap.com", "test email"); - }catch (HttpException e) { - - } catch (IOException e) { - // TODO Auto-generated catch block - e.printStackTrace(); - } - catch (NullPointerException e) { - assertTrue(true); - } - - } - - + + @Test + public void getTopicsTest() { + final Collection hosts = new LinkedList(); + hosts.add("localhost:" + 3904); + + MRMetaClient c; + try { + c = new MRMetaClient(hosts); + Set setString = c.getTopics(); + } catch (IOException e) { + e.printStackTrace(); + } + assertNotNull(hosts); + + + //assertEquals ("http://localhost:8080/events/" + "topic/cg/cid", url ); + + } + + @Test + public void getTopicMetadataTest() { + final Collection hosts = new LinkedList(); + hosts.add("localhost:" + 3904); + + final String topic = "topic1"; + + MRMetaClient c; + try { + c = new MRMetaClient(hosts); + TopicInfo topicInfo = c.getTopicMetadata(topic); + } catch (IOException | HttpObjectNotFoundException e) { + e.printStackTrace(); + } + assertNotNull(topic); + + } + + @Test + public void testcreateTopic() { + final Collection hosts = new LinkedList(); + hosts.add("localhost:" + 3904); + + MRMetaClient c; + try { + c = new MRMetaClient(hosts); + c.createTopic("topic1", "testTopic", 1, 1); + } catch (IOException | HttpException e) { + e.printStackTrace(); + } + assertNotNull(hosts); + } + + @Test + public void testupdateApiKey() { + final Collection hosts = new LinkedList(); + hosts.add("localhost:" + 3904); + + MRMetaClient c; + try { + c = new MRMetaClient(hosts); + c.updateCurrentApiKey("test@onap.com", "test email"); + } catch (HttpException e) { + + } catch (IOException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } catch (NullPointerException e) { + assertTrue(true); + } + + } + + }