@Before\r
public void setUp() throws Exception {\r
\r
- /* for (int i = 0; i < 10; i++) {\r
+ for (int i = 0; i < 10; i++) {\r
hostSet.add("host" + (i + 1));\r
hostArray[i] = "host" + (i + 1);\r
}\r
\r
pBuilder = new MRClientBuilders.PublisherBuilder();\r
\r
- mrcBuilders = new MRClientBuilders();*/\r
+ mrcBuilders = new MRClientBuilders();\r
\r
}\r
\r
@Test\r
public void testOnTopic() {\r
\r
-/* builder.onTopic("testTopic");\r
- assertTrue(true);*/\r
+ builder.onTopic("testTopic");\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testKnownAs() {\r
\r
- /* builder.knownAs("CG1", "23");\r
+ builder.knownAs("CG1", "23");\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
@Test\r
public void testAuthenticatedBy() {\r
\r
-/* builder.authenticatedBy("apikey", "apisecret");\r
- assertTrue(true);*/\r
+ builder.authenticatedBy("apikey", "apisecret");\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testWaitAtServer() {\r
\r
-// builder.waitAtServer(100);\r
-// assertTrue(true);\r
+ builder.waitAtServer(100);\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testReceivingAtMost() {\r
\r
- /*builder.receivingAtMost(100);\r
- assertTrue(true);*/\r
+ builder.receivingAtMost(100);\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testWithServerSideFilter() {\r
\r
- /*builder.withServerSideFilter("filter");\r
- assertTrue(true);*/\r
+ builder.withServerSideFilter("filter");\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testBuild() {\r
\r
- /* try {\r
+ try {\r
\r
builder.build();\r
} catch (IllegalArgumentException e) {\r
assertTrue(true);\r
- }*/\r
+ }\r
\r
}\r
\r
@Test\r
public void testUsingHosts3() {\r
\r
-/* pBuilder.usingHosts("testTopic");\r
+ /*pBuilder.usingHosts("testTopic");\r
assertTrue(true);\r
*/\r
}\r
@Test\r
public void testWithCompresion() {\r
\r
- /* pBuilder.withCompresion();\r
- assertTrue(true);*/\r
+ pBuilder.withCompresion();\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testWithoutCompresion() {\r
\r
- /* pBuilder.withoutCompresion();\r
- assertTrue(true);*/\r
+ pBuilder.withoutCompresion();\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testEnableCompresion() {\r
\r
- /* pBuilder.enableCompresion(true);\r
- assertTrue(true);*/\r
+ pBuilder.enableCompresion(true);\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testAuthenticatedBy2() {\r
\r
- /* pBuilder.authenticatedBy("apikey", "apisecret");\r
- assertTrue(true);*/\r
+ pBuilder.authenticatedBy("apikey", "apisecret");\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testBuild2() {\r
\r
- /* try {\r
+ try {\r
\r
pBuilder.build();\r
} catch (IllegalArgumentException e) {\r
assertTrue(true);\r
- }*/\r
+ }\r
\r
}\r
\r
@Test\r
public void test$testInject() {\r
\r
- /*try {\r
+ try {\r
\r
mrcBuilders.$testInject(builder.build());\r
} catch (IllegalArgumentException e) {\r
assertTrue(true);\r
- }*/\r
+ }\r
\r
}\r
\r
@Test\r
public void test$testInject2() {\r
\r
-// try {\r
-//\r
-// mrcBuilders.$testInject(pBuilder.build());\r
-// } catch (IllegalArgumentException e) {\r
-// assertTrue(true);\r
-// }\r
+ try {\r
+\r
+ mrcBuilders.$testInject(pBuilder.build());\r
+ } catch (IllegalArgumentException e) {\r
+ assertTrue(true);\r
+ }\r
\r
}\r
}\r