X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Forg%2Fonap%2Fdmaap%2Fmr%2Fclient%2FMRClientBuildersTest.java;fp=src%2Ftest%2Fjava%2Fcom%2Fatt%2Fnsa%2Fmr%2Fclient%2FMRClientBuildersTest.java;h=388a91c01cc1086c9090e158159f3e6b492ce18e;hb=0cb18b0baa2cf750e557262d821bbf2a03326bbe;hp=9a0a3ce5758e187b354278ae8b03efaa409ed5e0;hpb=9775bb11c919b0a8d89d81abf1b1a76bb7592f78;p=dmaap%2Fmessagerouter%2Fdmaapclient.git diff --git a/src/test/java/com/att/nsa/mr/client/MRClientBuildersTest.java b/src/test/java/org/onap/dmaap/mr/client/MRClientBuildersTest.java similarity index 92% rename from src/test/java/com/att/nsa/mr/client/MRClientBuildersTest.java rename to src/test/java/org/onap/dmaap/mr/client/MRClientBuildersTest.java index 9a0a3ce..388a91c 100644 --- a/src/test/java/com/att/nsa/mr/client/MRClientBuildersTest.java +++ b/src/test/java/org/onap/dmaap/mr/client/MRClientBuildersTest.java @@ -1,248 +1,248 @@ -/*- - * ============LICENSE_START======================================================= - * ONAP Policy Engine - * ================================================================================ - * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * Modifications Copyright © 2018 IBM. - * ================================================================================ - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * ============LICENSE_END========================================================= - */ - -package com.att.nsa.mr.client; - -import static org.junit.Assert.assertTrue; - -import java.util.ArrayList; -import java.util.Collection; -import java.util.concurrent.TimeUnit; - -import org.junit.After; -import org.junit.Before; -import org.junit.Test; - -import com.att.nsa.mr.client.HostSelector; -import com.att.nsa.mr.client.MRClient; -import com.att.nsa.mr.client.MRClientBuilders; - -public class MRClientBuildersTest { - - private Collection hostSet = new ArrayList(); - private MRClientBuilders.ConsumerBuilder builder = null; - private MRClientBuilders.PublisherBuilder pBuilder = null; - private String[] hostArray = new String[10]; - - @Before - public void setUp() throws Exception { - - for (int i = 0; i < 10; i++) { - hostSet.add("host" + (i + 1)); - hostArray[i] = "host" + (i + 1); - } - - builder = new MRClientBuilders.ConsumerBuilder(); - - pBuilder = new MRClientBuilders.PublisherBuilder(); - - } - - @After - public void tearDown() throws Exception { - - } - - @Test - public void testUsingHosts() { - - builder.usingHosts("hostList"); - assertTrue(true); - - } - - @Test - public void testUsingHosts2() { - - builder.usingHosts(hostSet); - assertTrue(true); - - } - - @Test - public void testOnTopic() { - - builder.onTopic("testTopic"); - assertTrue(true); - - } - - @Test - public void testKnownAs() { - - builder.knownAs("CG1", "23"); - assertTrue(true); - - } - - @Test - public void testAuthenticatedBy() { - - builder.authenticatedBy("apikey", "apisecret"); - assertTrue(true); - - } - - @Test - public void testWaitAtServer() { - - builder.waitAtServer(100); - assertTrue(true); - - } - - @Test - public void testReceivingAtMost() { - - builder.receivingAtMost(100); - assertTrue(true); - - } - - @Test - public void testWithServerSideFilter() { - - builder.withServerSideFilter("filter"); - assertTrue(true); - - } - - @Test - public void testBuild() { - - try { - - builder.build(); - } catch (IllegalArgumentException e) { - assertTrue(true); - } - - } - - @Test - public void testUsingHosts3() { - - pBuilder.usingHosts("testTopic"); - assertTrue(true); - - } - - @Test - public void testUsingHosts4() { - - pBuilder.usingHosts(hostArray); - assertTrue(true); - - } - - @Test - public void testUsingHosts5() { - - pBuilder.usingHosts(hostSet); - assertTrue(true); - - } - - @Test - public void testOnTopic2() { - - pBuilder.onTopic("testTopic"); - assertTrue(true); - - } - - @Test - public void testLimitBatch() { - - pBuilder.limitBatch(100, 10); - assertTrue(true); - - } - - @Test - public void testWithCompresion() { - - pBuilder.withCompresion(); - assertTrue(true); - - } - - @Test - public void testWithoutCompresion() { - - pBuilder.withoutCompresion(); - assertTrue(true); - - } - - @Test - public void testEnableCompresion() { - - pBuilder.enableCompresion(true); - assertTrue(true); - - } - - @Test - public void testAuthenticatedBy2() { - - pBuilder.authenticatedBy("apikey", "apisecret"); - assertTrue(true); - - } - - @Test - public void testBuild2() { - - try { - - pBuilder.build(); - } catch (IllegalArgumentException e) { - assertTrue(true); - } - - } - - @Test - public void test$testInject() { - - try { - - MRClientBuilders.$testInject(builder.build()); - } catch (IllegalArgumentException e) { - assertTrue(true); - } - - } - - @Test - public void test$testInject2() { - - try { - - MRClientBuilders.$testInject(pBuilder.build()); - } catch (IllegalArgumentException e) { - assertTrue(true); - } - - } -} +/*- + * ============LICENSE_START======================================================= + * ONAP Policy Engine + * ================================================================================ + * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * Modifications Copyright © 2018 IBM. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ + +package org.onap.dmaap.mr.client; + +import static org.junit.Assert.assertTrue; + +import java.util.ArrayList; +import java.util.Collection; +import java.util.concurrent.TimeUnit; + +import org.junit.After; +import org.junit.Before; +import org.junit.Test; + +import org.onap.dmaap.mr.client.HostSelector; +import org.onap.dmaap.mr.client.MRClient; +import org.onap.dmaap.mr.client.MRClientBuilders; + +public class MRClientBuildersTest { + + private Collection hostSet = new ArrayList(); + private MRClientBuilders.ConsumerBuilder builder = null; + private MRClientBuilders.PublisherBuilder pBuilder = null; + private String[] hostArray = new String[10]; + + @Before + public void setUp() throws Exception { + + for (int i = 0; i < 10; i++) { + hostSet.add("host" + (i + 1)); + hostArray[i] = "host" + (i + 1); + } + + builder = new MRClientBuilders.ConsumerBuilder(); + + pBuilder = new MRClientBuilders.PublisherBuilder(); + + } + + @After + public void tearDown() throws Exception { + + } + + @Test + public void testUsingHosts() { + + builder.usingHosts("hostList"); + assertTrue(true); + + } + + @Test + public void testUsingHosts2() { + + builder.usingHosts(hostSet); + assertTrue(true); + + } + + @Test + public void testOnTopic() { + + builder.onTopic("testTopic"); + assertTrue(true); + + } + + @Test + public void testKnownAs() { + + builder.knownAs("CG1", "23"); + assertTrue(true); + + } + + @Test + public void testAuthenticatedBy() { + + builder.authenticatedBy("apikey", "apisecret"); + assertTrue(true); + + } + + @Test + public void testWaitAtServer() { + + builder.waitAtServer(100); + assertTrue(true); + + } + + @Test + public void testReceivingAtMost() { + + builder.receivingAtMost(100); + assertTrue(true); + + } + + @Test + public void testWithServerSideFilter() { + + builder.withServerSideFilter("filter"); + assertTrue(true); + + } + + @Test + public void testBuild() { + + try { + + builder.build(); + } catch (IllegalArgumentException e) { + assertTrue(true); + } + + } + + @Test + public void testUsingHosts3() { + + pBuilder.usingHosts("testTopic"); + assertTrue(true); + + } + + @Test + public void testUsingHosts4() { + + pBuilder.usingHosts(hostArray); + assertTrue(true); + + } + + @Test + public void testUsingHosts5() { + + pBuilder.usingHosts(hostSet); + assertTrue(true); + + } + + @Test + public void testOnTopic2() { + + pBuilder.onTopic("testTopic"); + assertTrue(true); + + } + + @Test + public void testLimitBatch() { + + pBuilder.limitBatch(100, 10); + assertTrue(true); + + } + + @Test + public void testWithCompresion() { + + pBuilder.withCompresion(); + assertTrue(true); + + } + + @Test + public void testWithoutCompresion() { + + pBuilder.withoutCompresion(); + assertTrue(true); + + } + + @Test + public void testEnableCompresion() { + + pBuilder.enableCompresion(true); + assertTrue(true); + + } + + @Test + public void testAuthenticatedBy2() { + + pBuilder.authenticatedBy("apikey", "apisecret"); + assertTrue(true); + + } + + @Test + public void testBuild2() { + + try { + + pBuilder.build(); + } catch (IllegalArgumentException e) { + assertTrue(true); + } + + } + + @Test + public void test$testInject() { + + try { + + MRClientBuilders.$testInject(builder.build()); + } catch (IllegalArgumentException e) { + assertTrue(true); + } + + } + + @Test + public void test$testInject2() { + + try { + + MRClientBuilders.$testInject(pBuilder.build()); + } catch (IllegalArgumentException e) { + assertTrue(true); + } + + } +}