404405406407408409410411412413414
-1, groupAddress, groupPort, true); bg.start(); TransportConfiguration live1 = generateTC(); TransportConfiguration backup1 = generateTC();
451452453454455456457458459460461
511512513514515516517518519520521
null, -1, groupAddress1, groupPort1, true); bg1.start(); BroadcastGroup bg2 = new BroadcastGroupImpl(node2, RandomUtil.randomString(), null, -1,
520521522523524525526527528529530
null, -1, groupAddress2, groupPort2, true); bg2.start(); BroadcastGroup bg3 = new BroadcastGroupImpl(node3, RandomUtil.randomString(), null, -1,
529530531532533534535536537538539
null, -1, groupAddress3, groupPort3, true); bg3.start(); TransportConfiguration live1 = generateTC(); TransportConfiguration backup1 = generateTC(); TransportConfiguration live2 = generateTC();
7778798081828384858687
-1, groupAddress, groupPort, true); bg.start(); TransportConfiguration live1 = generateTC(); bg.addConnector(live1);
164165166167168169170171172173174
6552, groupAddress, groupPort, true); bg.start(); TransportConfiguration live1 = generateTC(); bg.addConnector(live1);
210211212213214215216217218219220
240241242243244245246247248249250
dg.stop(); dg.start(); bg.start(); bg.broadcastConnectors(); ok = dg.waitForBroadcast(1000);
272273274275276277278279280281282