264265266267268269270271272273274
if (bridge != null) { try { bridge.stop(); } catch (Exception e) { JMSBridgeReconnectionTest.log.error("Failed to stop bridge", e); }
347348349350351352353354355356357
556557558559560561562563564565566
} finally { if (bridge != null) { bridge.stop(); } } } public void testStartStopStart() throws Exception
594595596597598599600601602603604
false); bridge.setTransactionManager(newTransactionManager()); bridge.start(); bridge.stop(); bridge.start(); connSource = cf0.createConnection();
640641642643644645646647648649650
connTarget.close(); } if (bridge != null) { bridge.stop(); } removeAllMessages(sourceQueue.getQueueName(), 0); } }
740741742743744745746747748749750
829830831832833834835836837838839
JMSBridgeTest.log.error("Failed to resume", e); } } if (bridge != null) { bridge.stop(); } } } public void testNonDurableSubscriberLargeMessage() throws Exception
881882883884885886887888889890891
} finally { if (bridge != null) { bridge.stop(); } } } public void testDurableSubscriberLargeMessage() throws Exception
933934935936937938939940941942943
} finally { if (bridge != null) { bridge.stop(); } // Now unsubscribe Connection conn = cf0.createConnection(); conn.setClientID("clientid123");
11241125112611271128112911301131113211331134
} finally { if (bridge != null) { bridge.stop(); } if (connSource != null) { connSource.close();