From 7a06eb746b2f13b2630bb5e4b5846c0a1f7d7ded Mon Sep 17 00:00:00 2001 From: asgar Date: Wed, 12 Sep 2018 13:52:24 +0530 Subject: couple of fixes in MRClientBuilders.java Change-Id: Iad8229ec47c2fc08390f203edeb51acd74058e61 Issue-ID: DMAAP-770 Signed-off-by: Mohamed Asgar Samiulla --- .../att/nsa/mr/client/MRClientBuildersTest.java | 272 ++++++++++----------- 1 file changed, 135 insertions(+), 137 deletions(-) (limited to 'src/test/java/com') diff --git a/src/test/java/com/att/nsa/mr/client/MRClientBuildersTest.java b/src/test/java/com/att/nsa/mr/client/MRClientBuildersTest.java index 2e7d05d..9a0a3ce 100644 --- a/src/test/java/com/att/nsa/mr/client/MRClientBuildersTest.java +++ b/src/test/java/com/att/nsa/mr/client/MRClientBuildersTest.java @@ -4,6 +4,8 @@ * ================================================================================ * 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 @@ -36,215 +38,211 @@ 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 MRClientBuilders mrcBuilders = null; - - private String[] hostArray = new String[10]; - - @Before - public void setUp() throws Exception { + private Collection hostSet = new ArrayList(); + private MRClientBuilders.ConsumerBuilder builder = null; + private MRClientBuilders.PublisherBuilder pBuilder = null; + private String[] hostArray = new String[10]; - for (int i = 0; i < 10; i++) { - hostSet.add("host" + (i + 1)); - hostArray[i] = "host" + (i + 1); - } + @Before + public void setUp() throws Exception { - builder = new MRClientBuilders.ConsumerBuilder(); + for (int i = 0; i < 10; i++) { + hostSet.add("host" + (i + 1)); + hostArray[i] = "host" + (i + 1); + } - pBuilder = new MRClientBuilders.PublisherBuilder(); + builder = new MRClientBuilders.ConsumerBuilder(); - mrcBuilders = new MRClientBuilders(); + pBuilder = new MRClientBuilders.PublisherBuilder(); - } + } - @After - public void tearDown() throws Exception { + @After + public void tearDown() throws Exception { - } + } - @Test - public void testUsingHosts() { + @Test + public void testUsingHosts() { - builder.usingHosts("hostList"); - assertTrue(true); + builder.usingHosts("hostList"); + assertTrue(true); - } + } - @Test - public void testUsingHosts2() { + @Test + public void testUsingHosts2() { - builder.usingHosts(hostSet); - assertTrue(true); + builder.usingHosts(hostSet); + assertTrue(true); - } + } - @Test - public void testOnTopic() { + @Test + public void testOnTopic() { - builder.onTopic("testTopic"); - assertTrue(true); + builder.onTopic("testTopic"); + assertTrue(true); - } + } - @Test - public void testKnownAs() { + @Test + public void testKnownAs() { - builder.knownAs("CG1", "23"); - assertTrue(true); + builder.knownAs("CG1", "23"); + assertTrue(true); - } + } - @Test - public void testAuthenticatedBy() { + @Test + public void testAuthenticatedBy() { - builder.authenticatedBy("apikey", "apisecret"); - assertTrue(true); + builder.authenticatedBy("apikey", "apisecret"); + assertTrue(true); - } + } - @Test - public void testWaitAtServer() { + @Test + public void testWaitAtServer() { - builder.waitAtServer(100); - assertTrue(true); + builder.waitAtServer(100); + assertTrue(true); - } + } - @Test - public void testReceivingAtMost() { + @Test + public void testReceivingAtMost() { - builder.receivingAtMost(100); - assertTrue(true); + builder.receivingAtMost(100); + assertTrue(true); - } + } - @Test - public void testWithServerSideFilter() { + @Test + public void testWithServerSideFilter() { - builder.withServerSideFilter("filter"); - assertTrue(true); + builder.withServerSideFilter("filter"); + assertTrue(true); - } + } - @Test - public void testBuild() { + @Test + public void testBuild() { - try { + try { - builder.build(); - } catch (IllegalArgumentException e) { - assertTrue(true); - } + builder.build(); + } catch (IllegalArgumentException e) { + assertTrue(true); + } - } + } - @Test - public void testUsingHosts3() { + @Test + public void testUsingHosts3() { - pBuilder.usingHosts("testTopic"); - assertTrue(true); + pBuilder.usingHosts("testTopic"); + assertTrue(true); - } + } - @Test - public void testUsingHosts4() { + @Test + public void testUsingHosts4() { - pBuilder.usingHosts(hostArray); - assertTrue(true); + pBuilder.usingHosts(hostArray); + assertTrue(true); - } + } - @Test - public void testUsingHosts5() { + @Test + public void testUsingHosts5() { - pBuilder.usingHosts(hostSet); - assertTrue(true); + pBuilder.usingHosts(hostSet); + assertTrue(true); - } + } - @Test - public void testOnTopic2() { + @Test + public void testOnTopic2() { - pBuilder.onTopic("testTopic"); - assertTrue(true); + pBuilder.onTopic("testTopic"); + assertTrue(true); - } + } - @Test - public void testLimitBatch() { + @Test + public void testLimitBatch() { - pBuilder.limitBatch(100, 10); - assertTrue(true); + pBuilder.limitBatch(100, 10); + assertTrue(true); - } + } - @Test - public void testWithCompresion() { + @Test + public void testWithCompresion() { - pBuilder.withCompresion(); - assertTrue(true); + pBuilder.withCompresion(); + assertTrue(true); - } + } - @Test - public void testWithoutCompresion() { + @Test + public void testWithoutCompresion() { - pBuilder.withoutCompresion(); - assertTrue(true); + pBuilder.withoutCompresion(); + assertTrue(true); - } + } - @Test - public void testEnableCompresion() { + @Test + public void testEnableCompresion() { - pBuilder.enableCompresion(true); - assertTrue(true); + pBuilder.enableCompresion(true); + assertTrue(true); - } + } - @Test - public void testAuthenticatedBy2() { + @Test + public void testAuthenticatedBy2() { - pBuilder.authenticatedBy("apikey", "apisecret"); - assertTrue(true); + pBuilder.authenticatedBy("apikey", "apisecret"); + assertTrue(true); - } + } - @Test - public void testBuild2() { + @Test + public void testBuild2() { - try { + try { - pBuilder.build(); - } catch (IllegalArgumentException e) { - assertTrue(true); - } + pBuilder.build(); + } catch (IllegalArgumentException e) { + assertTrue(true); + } - } + } - @Test - public void test$testInject() { + @Test + public void test$testInject() { - try { + try { - mrcBuilders.$testInject(builder.build()); - } catch (IllegalArgumentException e) { - assertTrue(true); - } + MRClientBuilders.$testInject(builder.build()); + } catch (IllegalArgumentException e) { + assertTrue(true); + } - } + } - @Test - public void test$testInject2() { + @Test + public void test$testInject2() { - try { + try { - mrcBuilders.$testInject(pBuilder.build()); - } catch (IllegalArgumentException e) { - assertTrue(true); - } + MRClientBuilders.$testInject(pBuilder.build()); + } catch (IllegalArgumentException e) { + assertTrue(true); + } - } + } } -- cgit 1.2.3-korg