@Test\r
public void testSelectBaseHost() {\r
\r
-// HostSelector selector = new HostSelector("host");\r
-// \r
-// selector.selectBaseHost();\r
-// assertTrue(true);\r
-// \r
+ HostSelector selector = new HostSelector("host");\r
+ \r
+ selector.selectBaseHost();\r
+ assertTrue(true);\r
+ \r
\r
}\r
\r
@Test\r
public void testReportReachabilityProblem() {\r
\r
-/* HostSelector selector = new HostSelector("host");\r
+ HostSelector selector = new HostSelector("host");\r
\r
selector.reportReachabilityProblem(100, null);\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
\r
}\r
@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
@Test\r
public void testCreateConsumer() {\r
\r
- /* MRClientFactory.createConsumer("hostList hostList2", "testTopic");\r
- assertTrue(true);*/\r
-\r
+ /*MRClientFactory.createConsumer("hostList hostList2", "testTopic");\r
+ assertTrue(true);\r
+*/\r
}\r
\r
@Test\r
@Test\r
public void testCreateConsumer3() {\r
\r
- /* MRClientFactory.createConsumer(hostSet, "testTopic", "filter");\r
- assertTrue(true);*/\r
-\r
+ /*MRClientFactory.createConsumer(hostSet, "testTopic", "filter");\r
+ assertTrue(true);\r
+*/\r
}\r
\r
@Test\r
@Test\r
public void testCreateConsumer7() {\r
\r
-/* MRClientFactory.createConsumer(hostSet, "testTopic", "CG1", "22", 100, 100, "filter", "apikey", "apisecret");\r
+ /*MRClientFactory.createConsumer(hostSet, "testTopic", "CG1", "22", 100, 100, "filter", "apikey", "apisecret");\r
assertTrue(true);*/\r
\r
}\r
\r
@Test\r
public void testCreateIdentityManager() {\r
-/*\r
+\r
MRClientFactory.createIdentityManager(hostSet, "apikey", "apisecret");\r
\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCreateTopicManager() {\r
\r
- /* MRClientFactory.createTopicManager(hostSet, "apikey", "apisecret");\r
+ MRClientFactory.createTopicManager(hostSet, "apikey", "apisecret");\r
\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCreateConsumer8() {\r
-/*\r
+\r
try {\r
MRClientFactory.createConsumer("/consumer");\r
} catch (IOException e) {\r
e.printStackTrace();\r
}\r
\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCreateConsumer9() {\r
\r
-// MRClientFactory.createConsumer("host", "topic", "username", "password", "group", "23", "protocolFlag",\r
-// "/consumer", 1, 2);\r
-//\r
-// assertTrue(true);\r
+ /*MRClientFactory.createConsumer("host", "topic", "username", "password", "group", "23", "protocolFlag",\r
+ "/consumer", 1, 2);\r
\r
+ assertTrue(true);\r
+*/\r
}\r
\r
@Test\r
public void testCreateConsumer10() {\r
\r
-// MRClientFactory.createConsumer("host", "topic", "username", "password", "group", "23", 1, 2, "protocolFlag",\r
-// "/consumer");\r
-//\r
-// assertTrue(true);\r
+ /*MRClientFactory.createConsumer("host", "topic", "username", "password", "group", "23", 1, 2, "protocolFlag",\r
+ "/consumer");\r
+\r
+ assertTrue(true);*/\r
\r
}\r
\r
@Test\r
public void test$testInject() {\r
\r
-/* MRClientFactory.$testInject(null);\r
- assertTrue(true);*/\r
+ MRClientFactory.$testInject(null);\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testHandleEndpointFailover() {\r
\r
-// handler.handleEndpointFailover(null);\r
-// assertTrue(true);\r
+ /* handler.handleEndpointFailover(null);\r
+ assertTrue(true);*/\r
\r
}\r
\r
@Test\r
public void testPublishMessage() {\r
\r
-/* try {\r
+ try {\r
pub.publishMessage("/producer");\r
} catch (Exception e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
\r
@Test\r
public void testClose() {\r
- /*try {\r
+ try {\r
appender.close();\r
} catch (NullPointerException e) {\r
assertTrue(true);\r
}\r
\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
@Test\r
public void testRequiresLayout() {\r
-/*\r
+\r
appender.requiresLayout();\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testAppend() {\r
\r
- /*try {\r
+ try {\r
appender.append(null);\r
} catch (NullPointerException e) {\r
assertTrue(true);\r
}\r
\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
@Test\r
public void testActivateOptions() {\r
\r
-/* appender.activateOptions();\r
- assertTrue(true);*/\r
+ appender.activateOptions();\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testGetTopic() {\r
\r
- /* appender.getTopic();\r
+ appender.getTopic();\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
@Test\r
public void testSetTopic() {\r
\r
- /*appender.setTopic("testTopic");\r
+ appender.setTopic("testTopic");\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
@Test\r
public void testGetPartition() {\r
\r
- /* appender.getPartition();\r
+ appender.getPartition();\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
@Test\r
public void testSetPartition() {\r
\r
- /* appender.setPartition("partition");\r
- assertTrue(true);*/\r
+ appender.setPartition("partition");\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testGetHosts() {\r
\r
-/* appender.getHosts();\r
- assertTrue(true);*/\r
+ appender.getHosts();\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testSetHosts() {\r
-/*\r
+\r
appender.setHosts("hosts");\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
@Test\r
public void testGetMaxBatchSize() {\r
\r
- /*appender.getMaxBatchSize();\r
- assertTrue(true);*/\r
+ appender.getMaxBatchSize();\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testSetMaxBatchSize() {\r
\r
- /* appender.setMaxBatchSize(20);\r
- assertTrue(true);*/\r
+ appender.setMaxBatchSize(20);\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testGetMaxAgeMs() {\r
\r
- /*appender.getMaxAgeMs();\r
- assertTrue(true);*/\r
+ appender.getMaxAgeMs();\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testSetMaxAgeMs() {\r
\r
- /*appender.setMaxAgeMs(15);\r
- assertTrue(true);*/\r
+ appender.setMaxAgeMs(15);\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testIsCompress() {\r
\r
- /* appender.isCompress();\r
- assertTrue(true);*/\r
+ appender.isCompress();\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testSetCompress() {\r
\r
- /* appender.setCompress(true);\r
- assertTrue(true);*/\r
+ appender.setCompress(true);\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testMain() {\r
\r
-// try {\r
-// ConsolePublisher.main(null);\r
-// } catch (Exception e) {\r
-// // TODO Auto-generated catch block\r
-// e.printStackTrace();\r
-// }\r
-// assertTrue(true);\r
+ try {\r
+ ConsolePublisher.main(null);\r
+ } catch (Exception e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ }\r
+ assertTrue(true);\r
\r
}\r
\r
\r
@Before\r
public void setUp() throws Exception {\r
- //constants = new ProtocolTypeConstants();\r
+ // constants = new ProtocolTypeConstants();\r
\r
}\r
\r
@Test\r
public void testGetValue() {\r
\r
-// try {\r
-// constants.getValue();\r
-// } catch (Exception e) {\r
-// // TODO Auto-generated catch block\r
-// e.printStackTrace();\r
-// }\r
-// assertTrue(true);\r
+ try {\r
+ constants.getValue();\r
+ } catch (Exception e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ }\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testMain() {\r
\r
- /* try {\r
+ try {\r
SampleConsumer.main(null);\r
} catch (Exception e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testMain() {\r
\r
- /* try {\r
+ try {\r
SamplePublisher.main(null);\r
} catch (Exception e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
}\r
@Test\r
public void testMain() {\r
\r
- /*try {\r
+ try {\r
SimpleExampleConsumer.main(null);\r
} catch (Exception e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testMain() {\r
\r
-// try {\r
-// SimpleExampleConsumerWithReturnResponse.main(null);\r
-// } catch (Exception e) {\r
-// // TODO Auto-generated catch block\r
-// e.printStackTrace();\r
-// }\r
-// assertTrue(true);\r
+ /*try {\r
+ SimpleExampleConsumerWithReturnResponse.main(null);\r
+ } catch (Exception e) {\r
+ // TODO Auto-generated catch block e.printStackTrace();\r
+ }\r
+ assertTrue(true);*/\r
\r
}\r
\r
\r
@Test\r
public void testPublishMessage() {\r
- /* try {\r
+ try {\r
pub.publishMessage("/producer");\r
} catch (NullPointerException e) {\r
assertTrue(true);\r
e.printStackTrace();\r
}\r
\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testMain() {\r
\r
-// try {\r
-// SimpleExamplePublisher.main(null);\r
-// } catch (Exception e) {\r
-// // TODO Auto-generated catch block\r
-// e.printStackTrace();\r
-// }\r
-// assertTrue(true);\r
+ try {\r
+ SimpleExamplePublisher.main(null);\r
+ } catch (Exception e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ }\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testMain() {\r
\r
- /* try {\r
+ try {\r
SimpleExamplePublisherWithResponse.main(null);\r
} catch (Exception e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testPublishMessage() {\r
\r
- /* try {\r
+ try {\r
pub.publishMessage("/producer", 100);\r
} catch (Exception e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
}\r
@Test\r
public void testExecute() {\r
\r
- /* try {\r
+ try {\r
command.execute(parts, new MRCommandContext(), new PrintStream("/filename"));\r
} catch (CommandNotReadyException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
\r
@Test\r
public void testDisplayHelp() {\r
\r
- /*try {\r
+ try {\r
command.displayHelp(new PrintStream("/filename"));\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testExecute() {\r
\r
- /* try {\r
+ try {\r
command.execute(parts, new MRCommandContext(), new PrintStream("/filename"));\r
} catch (CommandNotReadyException e) {\r
// TODO Auto-generated catch block\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testDisplayHelp() {\r
\r
-/* try {\r
+ try {\r
command.displayHelp(new PrintStream("/filename"));\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testGetMatches() {\r
\r
- /* command.getMatches();\r
- assertTrue(true);*/\r
+ command.getMatches();\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCheckReady() {\r
\r
-/* try {\r
+ try {\r
command.checkReady(new MRCommandContext());\r
} catch (CommandNotReadyException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testExecute() {\r
\r
- /*try {\r
+ try {\r
command.execute(parts, new MRCommandContext(), new PrintStream("/filename"));\r
} catch (CommandNotReadyException e) {\r
// TODO Auto-generated catch block\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testDisplayHelp() {\r
\r
- /* try {\r
+ try {\r
command.displayHelp(new PrintStream("/filename"));\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testExecute() {\r
\r
- /*try {\r
+ try {\r
command.execute(parts, new MRCommandContext(), new PrintStream("/filename"));\r
} catch (CommandNotReadyException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
\r
@Test\r
public void testDisplayHelp() {\r
\r
- /* try {\r
+ try {\r
command.displayHelp(new PrintStream("/filename"));\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testExecute() {\r
\r
-/* try {\r
+ try {\r
command.execute(parts, new MRCommandContext(), new PrintStream("/filename"));\r
} catch (CommandNotReadyException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
\r
@Test\r
public void testDisplayHelp() {\r
\r
- /*try {\r
+ try {\r
command.displayHelp(new PrintStream("/filename"));\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testExecute() {\r
\r
- /*try {\r
+ try {\r
command.execute(parts, new MRCommandContext(), new PrintStream("/filename"));\r
} catch (CommandNotReadyException e) {\r
// TODO Auto-generated catch block\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testDisplayHelp() {\r
\r
-/* try {\r
+ try {\r
command.displayHelp(new PrintStream("/filename"));\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r