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