1 package org.apache.helix.integration;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import java.util.Date;
23
24 import org.apache.helix.TestHelper;
25 import org.apache.helix.TestHelper.StartCMResult;
26 import org.apache.log4j.Logger;
27 import org.testng.annotations.Test;
28
29
30 public class TestParticipantNameCollision extends ZkStandAloneCMTestBase
31 {
32 private static Logger logger = Logger.getLogger(TestParticipantNameCollision.class);
33
34 @Test()
35 public void testParticiptantNameCollision() throws Exception
36 {
37 logger.info("RUN TestParticipantNameCollision() at " + new Date(System.currentTimeMillis()));
38
39 StartCMResult result = null;
40 for (int i = 0; i < 1; i++)
41 {
42 String instanceName = "localhost_" + (START_PORT + i);
43 try
44 {
45
46
47 result = TestHelper.startDummyProcess(ZK_ADDR, CLUSTER_NAME, instanceName);
48 }
49 catch (Exception e)
50 {
51 e.printStackTrace();
52 }
53 }
54
55
56 Thread.sleep(30000);
57 TestHelper.verifyWithTimeout("verifyNotConnected", 30 * 1000, result._manager);
58
59 logger.info("STOP TestParticipantNameCollision() at " + new Date(System.currentTimeMillis()));
60 }
61 }