529530531532533534535536537538539
managementService.registerBridge(bridge, config); if (start) { bridge.start(); } } public void destroyBridge(final String name) throws Exception
199200201202203204205206207208209
producer0.send(message); } Assert.assertNull(consumer1.receiveImmediate()); bridge.start(); for (int i = 0; i < numMessages; i++) { ClientMessage message = consumer1.receive(1000);
573574575576577578579580581582583
// 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++) {
749750751752753754755756757758759
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
784785786787788789790791792793794
202203204205206207208209210211212
producer0.send(message); } Assert.assertNull(consumer1.receiveImmediate()); bridge.start(); for (int i = 0; i < numMessages; i++) { ClientMessage message = consumer1.receive(BridgeWithDiscoveryGroupStartTest.TIMEOUT);
530531532533534535536537538539540
454455456457458459460461462463464
records.put(nodeID, record); if (start) { bridge.start(); } } // Inner classes -----------------------------------------------------------------------------------
691692693694695696697698699700701
managementService.registerBridge(bridge, config); if (!backup) { bridge.start(); } } public synchronized void destroyBridge(final String name) throws Exception {
498499500501502503504505506507508
bridges.put(config.getName(), bridge); managementService.registerBridge(bridge, config); bridge.start(); } public synchronized void destroyBridge(final String name) throws Exception { Bridge bridge = bridges.remove(name);