src/test/java/org/onap/dmaap/mr/client/MRClientBuildersTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP Policy Engine
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  *  Modifications Copyright © 2018 IBM.
   8  * ================================================================================
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  * ============LICENSE_END=========================================================
  21  */
  22
  23 package org.onap.dmaap.mr.client;
  24
  25 import static org.junit.Assert.assertTrue;
  26
  27 import java.util.ArrayList;
  28 import java.util.Collection;
  29
  30 import org.junit.After;
  31 import org.junit.Before;
  32 import org.junit.Test;
  33 import org.onap.dmaap.mr.client.MRClientBuilders;
  34
  35 public class MRClientBuildersTest {
  36
  37     private Collection<String> hostSet = new ArrayList<String>();
  38     private MRClientBuilders.ConsumerBuilder builder = null;
  39     private MRClientBuilders.PublisherBuilder pBuilder = null;
  40     private String[] hostArray = new String[10];
  41
  42     @Before
  43     public void setUp() throws Exception {
  44
  45         for (int i = 0; i < 10; i++) {
  46             hostSet.add("host" + (i + 1));
  47             hostArray[i] = "host" + (i + 1);
  48         }
  49
  50         builder = new MRClientBuilders.ConsumerBuilder();
  51
  52         pBuilder = new MRClientBuilders.PublisherBuilder();
  53
  54     }
  55
  56     @After
  57     public void tearDown() throws Exception {
  58
  59     }
  60
  61     @Test
  62     public void testUsingHosts() {
  63
  64         builder.usingHosts("hostList");
  65         assertTrue(true);
  66
  67     }
  68
  69     @Test
  70     public void testUsingHosts2() {
  71
  72         builder.usingHosts(hostSet);
  73         assertTrue(true);
  74
  75     }
  76
  77     @Test
  78     public void testOnTopic() {
  79
  80         builder.onTopic("testTopic");
  81         assertTrue(true);
  82
  83     }
  84
  85     @Test
  86     public void testKnownAs() {
  87
  88         builder.knownAs("CG1", "23");
  89         assertTrue(true);
  90
  91     }
  92
  93     @Test
  94     public void testAuthenticatedBy() {
  95
  96         builder.authenticatedBy("apikey", "apisecret");
  97         assertTrue(true);
  98
  99     }
 100
 101     @Test
 102     public void testWaitAtServer() {
 103
 104         builder.waitAtServer(100);
 105         assertTrue(true);
 106
 107     }
 108
 109     @Test
 110     public void testReceivingAtMost() {
 111
 112         builder.receivingAtMost(100);
 113         assertTrue(true);
 114
 115     }
 116
 117     @Test
 118     public void testWithServerSideFilter() {
 119
 120         builder.withServerSideFilter("filter");
 121         assertTrue(true);
 122
 123     }
 124
 125     @Test
 126     public void testBuild() {
 127
 128         try {
 129
 130             builder.build();
 131         } catch (IllegalArgumentException e) {
 132             assertTrue(true);
 133         }
 134
 135     }
 136
 137     @Test
 138     public void testUsingHosts3() {
 139
 140         pBuilder.usingHosts("testTopic");
 141         assertTrue(true);
 142
 143     }
 144
 145     @Test
 146     public void testUsingHosts4() {
 147
 148         pBuilder.usingHosts(hostArray);
 149         assertTrue(true);
 150
 151     }
 152
 153     @Test
 154     public void testUsingHosts5() {
 155
 156         pBuilder.usingHosts(hostSet);
 157         assertTrue(true);
 158
 159     }
 160
 161     @Test
 162     public void testOnTopic2() {
 163
 164         pBuilder.onTopic("testTopic");
 165         assertTrue(true);
 166
 167     }
 168
 169     @Test
 170     public void testLimitBatch() {
 171
 172         pBuilder.limitBatch(100, 10);
 173         assertTrue(true);
 174
 175     }
 176
 177     @Test
 178     public void testWithCompresion() {
 179
 180         pBuilder.withCompresion();
 181         assertTrue(true);
 182
 183     }
 184
 185     @Test
 186     public void testWithoutCompresion() {
 187
 188         pBuilder.withoutCompresion();
 189         assertTrue(true);
 190
 191     }
 192
 193     @Test
 194     public void testEnableCompresion() {
 195
 196         pBuilder.enableCompresion(true);
 197         assertTrue(true);
 198
 199     }
 200
 201     @Test
 202     public void testAuthenticatedBy2() {
 203
 204         pBuilder.authenticatedBy("apikey", "apisecret");
 205         assertTrue(true);
 206
 207     }
 208
 209     @Test
 210     public void testBuild2() {
 211
 212         try {
 213
 214             pBuilder.build();
 215         } catch (IllegalArgumentException e) {
 216             assertTrue(true);
 217         }
 218
 219     }
 220
 221     @Test
 222     public void test$testInject() {
 223
 224         try {
 225
 226             MRClientBuilders.$testInject(builder.build());
 227         } catch (IllegalArgumentException e) {
 228             assertTrue(true);
 229         }
 230
 231     }
 232
 233     @Test
 234     public void test$testInject2() {
 235
 236         try {
 237
 238             MRClientBuilders.$testInject(pBuilder.build());
 239         } catch (IllegalArgumentException e) {
 240             assertTrue(true);
 241         }
 242
 243     }
 244 }