186187188189190191192193194195196
producer0.send(message); } Assert.assertNull(consumer1.receiveImmediate()); bridge.start(); for (int i = 0; i < numMessages; i++) { ClientMessage message = consumer1.receive(1000);
547548549550551552553554555556557
// Now start the bridge manually Bridge bridge = server0.getClusterManager().getBridges().get(bridgeName); bridge.start(); // Messages should now be received for (int i = 0; i < numMessages; i++) {
716717718719720721722723724725726
producer0.send(message); } Assert.assertNull(consumer1.receiveImmediate()); bridge.start(); BridgeStartTest.log.info("started bridge"); // The previous messages will get resent, but with duplicate detection they will be rejected // at the target
749750751752753754755756757758759
198199200201202203204205206207208
producer0.send(message); } Assert.assertNull(consumer1.receiveImmediate()); bridge.start(); for (int i = 0; i < numMessages; i++) { ClientMessage message = consumer1.receive(BridgeWithDiscoveryGroupStartTest.TIMEOUT);
538539540541542543544545546547548
records.put(nodeID, record); if (start) { bridge.start(); } } // Inner classes -----------------------------------------------------------------------------------
199200201202203204205206207208209
573574575576577578579580581582583
784785786787788789790791792793794