@Test\r
public void testCreateConsumer() {\r
\r
- /*MRClientFactory.createConsumer("hostList hostList2", "testTopic");\r
+ MRClientFactory.createConsumer("hostList hostList2", "testTopic");\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
@Test\r
public void testCreateConsumer2() {\r
\r
- /* MRClientFactory.createConsumer(hostSet, "testTopic");\r
- assertTrue(true);*/\r
+ MRClientFactory.createConsumer(hostSet, "testTopic");\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCreateConsumer3() {\r
\r
- /*MRClientFactory.createConsumer(hostSet, "testTopic", "filter");\r
+ MRClientFactory.createConsumer(hostSet, "testTopic", "filter");\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
@Test\r
public void testCreateConsumer4() {\r
\r
-// MRClientFactory.createConsumer(hostSet, "testTopic", "CG1", "22");\r
-// assertTrue(true);\r
+ MRClientFactory.createConsumer(hostSet, "testTopic", "CG1", "22");\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCreateConsumer5() {\r
\r
-/* MRClientFactory.createConsumer(hostSet, "testTopic", "CG1", "22", 100, 100);\r
- assertTrue(true);*/\r
+ MRClientFactory.createConsumer(hostSet, "testTopic", "CG1", "22", 100, 100);\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCreateConsumer6() {\r
\r
- /* MRClientFactory.createConsumer("hostList", "testTopic", "CG1", "22", 100, 100, "filter", "apikey", "apisecret");\r
+ MRClientFactory.createConsumer("hostList", "testTopic", "CG1", "22", 100, 100, "filter", "apikey", "apisecret");\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
@Test\r
public void testCreateConsumer7() {\r
\r
- /*MRClientFactory.createConsumer(hostSet, "testTopic", "CG1", "22", 100, 100, "filter", "apikey", "apisecret");\r
- assertTrue(true);*/\r
+ MRClientFactory.createConsumer(hostSet, "testTopic", "CG1", "22", 100, 100, "filter", "apikey", "apisecret");\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCreateSimplePublisher() {\r
\r
-/* MRClientFactory.createSimplePublisher("hostList", "testTopic");\r
- assertTrue(true);*/\r
+ MRClientFactory.createSimplePublisher("hostList", "testTopic");\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCreateBatchingPublisher1() {\r
-/*\r
+\r
MRClientFactory.createBatchingPublisher("hostList", "testTopic", 100, 10);\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCreateBatchingPublisher2() {\r
-/*\r
+\r
MRClientFactory.createBatchingPublisher("hostList", "testTopic", 100, 10, true);\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
@Test\r
public void testCreateBatchingPublisher3() {\r
-/*\r
+\r
MRClientFactory.createBatchingPublisher(hostArray, "testTopic", 100, 10, true);\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCreateBatchingPublisher4() {\r
\r
-// MRClientFactory.createBatchingPublisher(hostSet, "testTopic", 100, 10, true);\r
-// assertTrue(true);\r
+ MRClientFactory.createBatchingPublisher(hostSet, "testTopic", 100, 10, true);\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCreateBatchingPublisher5() {\r
-//\r
-// MRClientFactory.createBatchingPublisher("host", "testTopic", "username", "password", 100, 10, true,\r
-// "protocolFlag", "/producer");\r
-// assertTrue(true);\r
+\r
+ MRClientFactory.createBatchingPublisher("host", "testTopic", "username", "password", 100, 10, true,\r
+ "protocolFlag", "/producer");\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCreateBatchingPublisher6() {\r
-//\r
-// try {\r
-// MRClientFactory.createBatchingPublisher("/producer");\r
-// } catch (IOException e) {\r
-// // TODO Auto-generated catch block\r
-// e.printStackTrace();\r
-// }\r
-// assertTrue(true);\r
+\r
+ try {\r
+ MRClientFactory.createBatchingPublisher("/producer");\r
+ } catch (IOException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ }\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testCreateBatchingPublisher7() {\r
\r
- /* try {\r
+ try {\r
MRClientFactory.createBatchingPublisher("/producer", true);\r
} catch (IOException 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 testCreateConsumer9() {\r
\r
- /*MRClientFactory.createConsumer("host", "topic", "username", "password", "group", "23", "protocolFlag",\r
+ MRClientFactory.createConsumer("host", "topic", "username", "password", "group", "23", "protocolFlag",\r
"/consumer", 1, 2);\r
\r
assertTrue(true);\r
-*/\r
+\r
}\r
\r
@Test\r
public void testCreateConsumer10() {\r
\r
- /*MRClientFactory.createConsumer("host", "topic", "username", "password", "group", "23", 1, 2, "protocolFlag",\r
+ MRClientFactory.createConsumer("host", "topic", "username", "password", "group", "23", 1, 2, "protocolFlag",\r
"/consumer");\r
\r
- assertTrue(true);*/\r
+ assertTrue(true);\r
\r
}\r
\r