10021003100410051006100710081009101010111012
} finally { if (bridge != null) { bridge.stop(); } if (connSource != null) { connSource.close();
10881089109010911092109310941095109610971098
11741175117611771178117911801181118211831184
} } if (bridge != null) { bridge.stop(); } } } private void testStressBatchTime(int qosMode, boolean persistent, int maxBatchTime) throws Exception
12471248124912501251125212531254125512561257
} } if (bridge != null) { bridge.stop(); } } } //Both source and destination on same rm
13211322132313241325132613271328132913301331
} } if (bridge != null) { bridge.stop(); } } }
13801381138213831384138513861387138813891390
finally { if (bridge != null) { log.info("Stopping bridge"); bridge.stop(); } } } private void testNoMaxBatchTimeSameServer(int qosMode, boolean persistent) throws Exception
14381439144014411442144314441445144614471448
} finally { if (bridge != null) { bridge.stop(); } } } private void testMaxBatchTime(int qosMode, boolean persistent) throws Exception
14791480148114821483148414851486148714881489
} finally { if (bridge != null) { bridge.stop(); } } } private void testMaxBatchTimeSameServer(int qosMode, boolean persistent) throws Exception
15221523152415251526152715281529153015311532
} finally { if (bridge != null) { bridge.stop(); } } }
496497498499500501502503504505506
} finally { if (bridge != null) { bridge.stop(); } } } public void testSelector() throws Exception