src/test/java/com/att/nsa/cambria/metrics/publisher/DMaaPCambriaClientFactoryTest.java

   1 /*-\r
   2  * ============LICENSE_START=======================================================\r
   3  * ONAP Policy Engine\r
   4  * ================================================================================\r
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.\r
   6  * ================================================================================\r
   7  * Licensed under the Apache License, Version 2.0 (the "License");\r
   8  * you may not use this file except in compliance with the License.\r
   9  * You may obtain a copy of the License at\r
  10  * \r
  11  *      http://www.apache.org/licenses/LICENSE-2.0\r
  12  * \r
  13  * Unless required by applicable law or agreed to in writing, software\r
  14  * distributed under the License is distributed on an "AS IS" BASIS,\r
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  16  * See the License for the specific language governing permissions and\r
  17  * limitations under the License.\r
  18  * ============LICENSE_END=========================================================\r
  19  */\r
  20 \r
  21 package com.att.nsa.cambria.metrics.publisher;\r
  22 \r
  23 import static org.junit.Assert.*;\r
  24 \r
  25 import java.util.ArrayList;\r
  26 import java.util.Collection;\r
  27 \r
  28 import org.junit.After;\r
  29 import org.junit.Before;\r
  30 import org.junit.Test;\r
  31 \r
  32 import com.att.dmf.mr.listener.DME2EndPointLoader;\r
  33 import com.att.dmf.mr.metrics.publisher.CambriaConsumer;\r
  34 import com.att.dmf.mr.metrics.publisher.CambriaPublisherUtility;\r
  35 import com.att.dmf.mr.metrics.publisher.DMaaPCambriaClientFactory;\r
  36 \r
  37 public class DMaaPCambriaClientFactoryTest {\r
  38         \r
  39         private Collection<String> hostSet;\r
  40         \r
  41         private String[] hostSetArray; \r
  42         @Before\r
  43         public void setUp() throws Exception {\r
  44                 hostSet = new ArrayList<String>();\r
  45                 \r
  46                 hostSetArray = new String[10];\r
  47                 \r
  48                 for (int i = 0; i < 10; i++) {\r
  49                         hostSet.add("host" + (i+1));\r
  50                         hostSetArray[i] = "host" + (i+1);\r
  51                 }\r
  52                 \r
  53         }\r
  54 \r
  55         @After\r
  56         public void tearDown() throws Exception {\r
  57         }\r
  58 \r
  59         @Test\r
  60         public void testCreateConsumer() {\r
  61                 \r
  62                 \r
  63                 \r
  64                 DMaaPCambriaClientFactory.createConsumer("hostList", "testTopic");\r
  65                 assertTrue(true);\r
  66                 \r
  67         }\r
  68         \r
  69         @Test\r
  70         public void testCreateConsumer2() {\r
  71                 \r
  72                 \r
  73                 try {\r
  74                         DMaaPCambriaClientFactory.createConsumer(hostSet, "testTopic");\r
  75                 } catch (NullPointerException e) {\r
  76                         assertTrue(true);\r
  77                 }\r
  78                 \r
  79                 \r
  80         }\r
  81         \r
  82         @Test\r
  83         public void testCreateConsumer3() {\r
  84                 \r
  85                 DMaaPCambriaClientFactory.createConsumer(hostSet, "testTopic", "filter");\r
  86                 assertTrue(true);\r
  87                 \r
  88         }\r
  89         \r
  90         @Test\r
  91         public void testCreateConsumer4() {\r
  92                 DMaaPCambriaClientFactory.createConsumer(hostSet, "testTopic", "CG1", "23");\r
  93                 assertTrue(true);\r
  94                 \r
  95         }\r
  96         \r
  97         @Test\r
  98         public void testCreateConsumer5() {\r
  99                 \r
 100                 DMaaPCambriaClientFactory.createConsumer(hostSet, "testTopic", "CG1", "23", 100, 20);\r
 101                 assertTrue(true);\r
 102                 \r
 103         }\r
 104         \r
 105         @Test\r
 106         public void testCreateConsumer6() {\r
 107                 \r
 108                 \r
 109                 DMaaPCambriaClientFactory.createConsumer("hostList", "testTopic", "CG1", "23", 100, 20, "filter", "apikey", "apisecret");\r
 110                 assertTrue(true);\r
 111                 \r
 112         }\r
 113         \r
 114         @Test\r
 115         public void testCreateConsumer7() {\r
 116                 \r
 117                 DMaaPCambriaClientFactory.createConsumer(hostSet, "testTopic", "CG1", "23", 100, 20, "filter", "apikey", "apisecret");\r
 118                 assertTrue(true);\r
 119                 \r
 120         }\r
 121         \r
 122         @Test\r
 123         public void testCreateSimplePublisher() {\r
 124                 \r
 125                 DMaaPCambriaClientFactory.createSimplePublisher("hostList", "testTopic");\r
 126                 assertTrue(true);\r
 127                 \r
 128         }\r
 129         \r
 130         @Test\r
 131         public void testCreateBatchingPublisher() {\r
 132                 \r
 133                 DMaaPCambriaClientFactory.createBatchingPublisher("hostList", "testTopic", 100, 50);\r
 134                 assertTrue(true);\r
 135                 \r
 136         }\r
 137         \r
 138         @Test\r
 139         public void testCreateBatchingPublisher2() {\r
 140                 \r
 141                 DMaaPCambriaClientFactory.createBatchingPublisher("hostList", "testTopic", 100, 50, true);\r
 142                 assertTrue(true);\r
 143                 \r
 144         }\r
 145         \r
 146         @Test\r
 147         public void testCreateBatchingPublisher3() {\r
 148                 \r
 149                 DMaaPCambriaClientFactory.createBatchingPublisher(hostSetArray, "testTopic", 100, 50, true);\r
 150                 assertTrue(true);\r
 151                 \r
 152         }\r
 153         \r
 154         @Test\r
 155         public void testCreateBatchingPublisher4() {\r
 156                 \r
 157                 DMaaPCambriaClientFactory.createBatchingPublisher(hostSet, "testTopic", 100, 50, true);\r
 158                 assertTrue(true);\r
 159                 \r
 160         }\r
 161         \r
 162         @Test\r
 163         public void $testInject() {\r
 164                 \r
 165                 DMaaPCambriaClientFactory factory = new DMaaPCambriaClientFactory();\r
 166                 factory.$testInject(null);\r
 167                 assertTrue(true);\r
 168                 \r
 169         }\r
 170         \r
 171 }\r