251252253254255256257258259260261
null, groupAddress, groupPort, timeout); dg.start(); bg.broadcastConnectors(); boolean ok = dg.waitForBroadcast(1000);
275276277278279280281282283284285
bg.stop(); dg.stop(); dg.start(); bg.start(); bg.broadcastConnectors();
328329330331332333334335336337338
bg.addConnectorPair(connectorPair); DiscoveryGroup dg = new DiscoveryGroupImpl(nodeID, RandomUtil.randomString(), null, groupAddress, groupPort, timeout); dg.start(); bg.broadcastConnectors(); boolean ok = dg.waitForBroadcast(1000);
424425426427428429430431432433434
null, groupAddress, port2, timeout); dg.start(); bg.broadcastConnectors(); boolean ok = dg.waitForBroadcast(1000);
472473474475476477478479480481482
null, groupAddress2, port2, timeout); dg.start(); bg.broadcastConnectors(); boolean ok = dg.waitForBroadcast(1000);
559560561562563564565566567568569
RandomUtil.randomString(), null, groupAddress1, groupPort1, timeout); dg1.start(); DiscoveryGroup dg2 = new DiscoveryGroupImpl(RandomUtil.randomString(), RandomUtil.randomString(), null, groupAddress2,
567568569570571572573574575576577
RandomUtil.randomString(), null, groupAddress2, groupPort2, timeout); dg2.start(); DiscoveryGroup dg3 = new DiscoveryGroupImpl(RandomUtil.randomString(), RandomUtil.randomString(), null, groupAddress3,
575576577578579580581582583584585
RandomUtil.randomString(), null, groupAddress3, groupPort3, timeout); dg3.start(); bg1.broadcastConnectors(); bg2.broadcastConnectors();
651652653654655656657658659660661
712713714715716717718719720721722
dg.registerListener(listener1); dg.registerListener(listener2); dg.registerListener(listener3); dg.start(); bg.broadcastConnectors(); boolean ok = dg.waitForBroadcast(1000); Assert.assertTrue(ok);