src/test/java/com/att/nsa/mr/client/MRClientFactoryTest.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  *  Modifications Copyright © 2018 IBM.\r
   8  * ================================================================================\r
   9  * Licensed under the Apache License, Version 2.0 (the "License");\r
  10  * you may not use this file except in compliance with the License.\r
  11  * You may obtain a copy of the License at\r
  12  * \r
  13  *      http://www.apache.org/licenses/LICENSE-2.0\r
  14  * \r
  15  * Unless required by applicable law or agreed to in writing, software\r
  16  * distributed under the License is distributed on an "AS IS" BASIS,\r
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  18  * See the License for the specific language governing permissions and\r
  19  * limitations under the License.\r
  20  * ============LICENSE_END=========================================================\r
  21  */\r
  22 \r
  23 package com.att.nsa.mr.client;\r
  24 \r
  25 import static org.junit.Assert.assertTrue;\r
  26 \r
  27 import java.io.IOException;\r
  28 import java.util.ArrayList;\r
  29 import java.util.Collection;\r
  30 import java.util.concurrent.TimeUnit;\r
  31 \r
  32 import org.junit.After;\r
  33 import org.junit.Before;\r
  34 import org.junit.Test;\r
  35 \r
  36 import com.att.nsa.mr.client.HostSelector;\r
  37 import com.att.nsa.mr.client.MRClient;\r
  38 import com.att.nsa.mr.client.MRClientBuilders;\r
  39 import com.att.nsa.mr.client.MRClientFactory;\r
  40 \r
  41 public class MRClientFactoryTest {\r
  42 \r
  43     private Collection<String> hostSet = new ArrayList<String>();\r
  44 \r
  45     private String[] hostArray = new String[10];\r
  46 \r
  47     @Before\r
  48     public void setUp() throws Exception {\r
  49 \r
  50         for (int i = 0; i < 10; i++) {\r
  51             hostSet.add("host" + (i + 1));\r
  52             hostArray[i] = "host" + (i + 1);\r
  53         }\r
  54     }\r
  55 \r
  56     @After\r
  57     public void tearDown() throws Exception {\r
  58 \r
  59     }\r
  60 \r
  61     @Test\r
  62     public void testCreateConsumer() {\r
  63 \r
  64         MRClientFactory.createConsumer("hostList hostList2", "testTopic");\r
  65         assertTrue(true);\r
  66 \r
  67     }\r
  68 \r
  69     @Test\r
  70     public void testCreateConsumer2() {\r
  71 \r
  72         MRClientFactory.createConsumer(hostSet, "testTopic");\r
  73         assertTrue(true);\r
  74 \r
  75     }\r
  76 \r
  77     @Test\r
  78     public void testCreateConsumer3() {\r
  79 \r
  80         MRClientFactory.createConsumer(hostSet, "testTopic", "filter");\r
  81         assertTrue(true);\r
  82 \r
  83     }\r
  84 \r
  85     @Test\r
  86     public void testCreateConsumer4() {\r
  87 \r
  88         MRClientFactory.createConsumer(hostSet, "testTopic", "CG1", "22");\r
  89         assertTrue(true);\r
  90 \r
  91     }\r
  92 \r
  93     @Test\r
  94     public void testCreateConsumer5() {\r
  95 \r
  96         MRClientFactory.createConsumer(hostSet, "testTopic", "CG1", "22", 100, 100);\r
  97         assertTrue(true);\r
  98 \r
  99     }\r
 100 \r
 101     @Test\r
 102     public void testCreateConsumer6() {\r
 103 \r
 104         MRClientFactory.createConsumer("hostList", "testTopic", "CG1", "22", 100, 100, "filter", "apikey", "apisecret");\r
 105         assertTrue(true);\r
 106 \r
 107     }\r
 108 \r
 109     @Test\r
 110     public void testCreateConsumer7() {\r
 111 \r
 112         MRClientFactory.createConsumer(hostSet, "testTopic", "CG1", "22", 100, 100, "filter", "apikey", "apisecret");\r
 113         assertTrue(true);\r
 114 \r
 115     }\r
 116 \r
 117     @Test\r
 118     public void testCreateSimplePublisher() {\r
 119 \r
 120         MRClientFactory.createSimplePublisher("hostList", "testTopic");\r
 121         assertTrue(true);\r
 122 \r
 123     }\r
 124 \r
 125     @Test\r
 126     public void testCreateBatchingPublisher1() {\r
 127 \r
 128         MRClientFactory.createBatchingPublisher("hostList", "testTopic", 100, 10);\r
 129         assertTrue(true);\r
 130 \r
 131     }\r
 132 \r
 133     @Test\r
 134     public void testCreateBatchingPublisher2() {\r
 135 \r
 136         MRClientFactory.createBatchingPublisher("hostList", "testTopic", 100, 10, true);\r
 137         assertTrue(true);\r
 138 \r
 139     }\r
 140 \r
 141     @Test\r
 142     public void testCreateBatchingPublisher3() {\r
 143 \r
 144         MRClientFactory.createBatchingPublisher(hostArray, "testTopic", 100, 10, true);\r
 145         assertTrue(true);\r
 146 \r
 147     }\r
 148 \r
 149     @Test\r
 150     public void testCreateBatchingPublisher4() {\r
 151 \r
 152     MRClientFactory.createBatchingPublisher(hostSet, "testTopic", 100, 10, true);\r
 153         assertTrue(true);\r
 154 \r
 155     }\r
 156 \r
 157     @Test\r
 158     public void testCreateBatchingPublisher5() {\r
 159 \r
 160         MRClientFactory.createBatchingPublisher("host", "testTopic", "username", "password", 100, 10, true,\r
 161                 "protocolFlag");\r
 162         assertTrue(true);\r
 163 \r
 164     }\r
 165 \r
 166     @Test\r
 167     public void testCreateBatchingPublisher6() {\r
 168 \r
 169         try {\r
 170             MRClientFactory.createBatchingPublisher("/producer");\r
 171         } catch (IOException e) {\r
 172             // TODO Auto-generated catch block\r
 173             e.printStackTrace();\r
 174         }\r
 175         assertTrue(true);\r
 176 \r
 177     }\r
 178 \r
 179     @Test\r
 180     public void testCreateBatchingPublisher7() {\r
 181 \r
 182         try {\r
 183             MRClientFactory.createBatchingPublisher("/producer", true);\r
 184         } catch (IOException e) {\r
 185             // TODO Auto-generated catch block\r
 186             e.printStackTrace();\r
 187         }\r
 188         assertTrue(true);\r
 189 \r
 190     }\r
 191 \r
 192     @Test\r
 193     public void testCreateIdentityManager() {\r
 194 \r
 195         MRClientFactory.createIdentityManager(hostSet, "apikey", "apisecret");\r
 196 \r
 197         assertTrue(true);\r
 198 \r
 199     }\r
 200 \r
 201     @Test\r
 202     public void testCreateTopicManager() {\r
 203 \r
 204         MRClientFactory.createTopicManager(hostSet, "apikey", "apisecret");\r
 205 \r
 206         assertTrue(true);\r
 207 \r
 208     }\r
 209 \r
 210     @Test\r
 211     public void testCreateConsumer8() {\r
 212 \r
 213         try {\r
 214             MRClientFactory.createConsumer("/consumer");\r
 215         } catch (IOException e) {\r
 216             // TODO Auto-generated catch block\r
 217             e.printStackTrace();\r
 218         }\r
 219 \r
 220         assertTrue(true);\r
 221 \r
 222     }\r
 223 \r
 224     @Test\r
 225     public void testCreateConsumer9() {\r
 226 \r
 227         MRClientFactory.createConsumer("host", "topic", "username", "password", "group", "23", "protocolFlag",\r
 228                 "/consumer", 1, 2);\r
 229 \r
 230         assertTrue(true);\r
 231 \r
 232     }\r
 233 \r
 234     @Test\r
 235     public void testCreateConsumer10() {\r
 236 \r
 237         MRClientFactory.createConsumer("host", "topic", "username", "password", "group", "23", 1, 2, "protocolFlag",\r
 238                 "/consumer");\r
 239 \r
 240         assertTrue(true);\r
 241 \r
 242     }\r
 243     \r
 244     @Test\r
 245     public void test$testInject() {\r
 246 \r
 247         MRClientFactory.$testInject(null);\r
 248         assertTrue(true);\r
 249 \r
 250     }\r
 251 \r
 252 }