src/test/java/com/att/nsa/mr/client/MRClientBuildersTest.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.util.ArrayList;\r
  28 import java.util.Collection;\r
  29 import java.util.concurrent.TimeUnit;\r
  30 \r
  31 import org.junit.After;\r
  32 import org.junit.Before;\r
  33 import org.junit.Test;\r
  34 \r
  35 import com.att.nsa.mr.client.HostSelector;\r
  36 import com.att.nsa.mr.client.MRClient;\r
  37 import com.att.nsa.mr.client.MRClientBuilders;\r
  38 \r
  39 public class MRClientBuildersTest {\r
  40 \r
  41     private Collection<String> hostSet = new ArrayList<String>();\r
  42     private MRClientBuilders.ConsumerBuilder builder = null;\r
  43     private MRClientBuilders.PublisherBuilder pBuilder = null;\r
  44     private String[] hostArray = new String[10];\r
  45 \r
  46     @Before\r
  47     public void setUp() throws Exception {\r
  48 \r
  49         for (int i = 0; i < 10; i++) {\r
  50             hostSet.add("host" + (i + 1));\r
  51             hostArray[i] = "host" + (i + 1);\r
  52         }\r
  53 \r
  54         builder = new MRClientBuilders.ConsumerBuilder();\r
  55 \r
  56         pBuilder = new MRClientBuilders.PublisherBuilder();\r
  57 \r
  58     }\r
  59 \r
  60     @After\r
  61     public void tearDown() throws Exception {\r
  62 \r
  63     }\r
  64 \r
  65     @Test\r
  66     public void testUsingHosts() {\r
  67 \r
  68         builder.usingHosts("hostList");\r
  69         assertTrue(true);\r
  70 \r
  71     }\r
  72 \r
  73     @Test\r
  74     public void testUsingHosts2() {\r
  75 \r
  76         builder.usingHosts(hostSet);\r
  77         assertTrue(true);\r
  78 \r
  79     }\r
  80 \r
  81     @Test\r
  82     public void testOnTopic() {\r
  83 \r
  84         builder.onTopic("testTopic");\r
  85         assertTrue(true);\r
  86 \r
  87     }\r
  88 \r
  89     @Test\r
  90     public void testKnownAs() {\r
  91 \r
  92         builder.knownAs("CG1", "23");\r
  93         assertTrue(true);\r
  94 \r
  95     }\r
  96 \r
  97     @Test\r
  98     public void testAuthenticatedBy() {\r
  99 \r
 100         builder.authenticatedBy("apikey", "apisecret");\r
 101         assertTrue(true);\r
 102 \r
 103     }\r
 104 \r
 105     @Test\r
 106     public void testWaitAtServer() {\r
 107 \r
 108         builder.waitAtServer(100);\r
 109         assertTrue(true);\r
 110 \r
 111     }\r
 112 \r
 113     @Test\r
 114     public void testReceivingAtMost() {\r
 115 \r
 116         builder.receivingAtMost(100);\r
 117         assertTrue(true);\r
 118 \r
 119     }\r
 120 \r
 121     @Test\r
 122     public void testWithServerSideFilter() {\r
 123 \r
 124         builder.withServerSideFilter("filter");\r
 125         assertTrue(true);\r
 126 \r
 127     }\r
 128 \r
 129     @Test\r
 130     public void testBuild() {\r
 131 \r
 132         try {\r
 133 \r
 134             builder.build();\r
 135         } catch (IllegalArgumentException e) {\r
 136             assertTrue(true);\r
 137         }\r
 138 \r
 139     }\r
 140 \r
 141     @Test\r
 142     public void testUsingHosts3() {\r
 143 \r
 144         pBuilder.usingHosts("testTopic");\r
 145         assertTrue(true);\r
 146 \r
 147     }\r
 148 \r
 149     @Test\r
 150     public void testUsingHosts4() {\r
 151 \r
 152         pBuilder.usingHosts(hostArray);\r
 153         assertTrue(true);\r
 154 \r
 155     }\r
 156 \r
 157     @Test\r
 158     public void testUsingHosts5() {\r
 159 \r
 160         pBuilder.usingHosts(hostSet);\r
 161         assertTrue(true);\r
 162 \r
 163     }\r
 164 \r
 165     @Test\r
 166     public void testOnTopic2() {\r
 167 \r
 168         pBuilder.onTopic("testTopic");\r
 169         assertTrue(true);\r
 170 \r
 171     }\r
 172 \r
 173     @Test\r
 174     public void testLimitBatch() {\r
 175 \r
 176         pBuilder.limitBatch(100, 10);\r
 177         assertTrue(true);\r
 178 \r
 179     }\r
 180 \r
 181     @Test\r
 182     public void testWithCompresion() {\r
 183 \r
 184         pBuilder.withCompresion();\r
 185         assertTrue(true);\r
 186 \r
 187     }\r
 188 \r
 189     @Test\r
 190     public void testWithoutCompresion() {\r
 191 \r
 192         pBuilder.withoutCompresion();\r
 193         assertTrue(true);\r
 194 \r
 195     }\r
 196 \r
 197     @Test\r
 198     public void testEnableCompresion() {\r
 199 \r
 200         pBuilder.enableCompresion(true);\r
 201         assertTrue(true);\r
 202 \r
 203     }\r
 204 \r
 205     @Test\r
 206     public void testAuthenticatedBy2() {\r
 207 \r
 208         pBuilder.authenticatedBy("apikey", "apisecret");\r
 209         assertTrue(true);\r
 210 \r
 211     }\r
 212 \r
 213     @Test\r
 214     public void testBuild2() {\r
 215 \r
 216         try {\r
 217 \r
 218             pBuilder.build();\r
 219         } catch (IllegalArgumentException e) {\r
 220             assertTrue(true);\r
 221         }\r
 222 \r
 223     }\r
 224 \r
 225     @Test\r
 226     public void test$testInject() {\r
 227 \r
 228         try {\r
 229 \r
 230             MRClientBuilders.$testInject(builder.build());\r
 231         } catch (IllegalArgumentException e) {\r
 232             assertTrue(true);\r
 233         }\r
 234 \r
 235     }\r
 236 \r
 237     @Test\r
 238     public void test$testInject2() {\r
 239 \r
 240         try {\r
 241 \r
 242             MRClientBuilders.$testInject(pBuilder.build());\r
 243         } catch (IllegalArgumentException e) {\r
 244             assertTrue(true);\r
 245         }\r
 246 \r
 247     }\r
 248 }\r