14231424142514261427142814291430143114321433
finally { if (bridge != null) { log.info("Stopping bridge"); bridge.stop(); } } } private void testNoMaxBatchTimeSameServer(int qosMode, boolean persistent) throws Exception
14811482148314841485148614871488148914901491
} finally { if (bridge != null) { bridge.stop(); } } } private void testMaxBatchTime(int qosMode, boolean persistent) throws Exception
15221523152415251526152715281529153015311532
} finally { if (bridge != null) { bridge.stop(); } } } private void testMaxBatchTimeSameServer(int qosMode, boolean persistent) throws Exception
15651566156715681569157015711572157315741575
} finally { if (bridge != null) { bridge.stop(); } } }
497498499500501502503504505506507
} finally { if (bridge != null) { bridge.stop(); } } } public void testSelector() throws Exception
598599600601602603604605606607608
} } if (bridge != null) { bridge.stop(); } try { ServerManagement.undeployQueue("sourceQueue", 0);
686687688689690691692693694695696
log.error("Failed to resume", e); } } if (bridge != null) { bridge.stop(); } } } public void testNonDurableSubscriber() throws Exception
720721722723724725726727728729730
} finally { if (bridge != null) { bridge.stop(); } } } public void testDurableSubscriber() throws Exception
754755756757758759760761762763764
} finally { if (bridge != null) { bridge.stop(); } } } public void testTimeout() throws Exception
808809810811812813814815816817818
finally { if (bridge != null) { log.info("Stopping bridge"); bridge.stop(); } } }