11071108110911101111111211131114111511161117
JMSBridgeTest.log.error("Failed to resume", e); } } if (bridge != null) { bridge.stop(); } } } public void testNonDurableSubscriberLargeMessage() throws Exception
11591160116111621163116411651166116711681169
} finally { if (bridge != null) { bridge.stop(); } } } public void testDurableSubscriberLargeMessage() throws Exception
12111212121312141215121612171218121912201221
} finally { if (bridge != null) { bridge.stop(); } // Now unsubscribe Connection conn = cf0.createConnection(); conn.setClientID("clientid123");
14021403140414051406140714081409141014111412
} finally { if (bridge != null) { bridge.stop(); } if (connSource != null) { connSource.close();
15961597159815991600160116021603160416051606
16951696169716981699170017011702170317041705
18011802180318041805180618071808180918101811
} } if (bridge != null) { bridge.stop(); } } } private void testStressBatchTime(final QualityOfServiceMode qosMode, final boolean persistent, final int maxBatchTime) throws Exception
18951896189718981899190019011902190319041905
} } if (bridge != null) { bridge.stop(); } } } // Both source and destination on same rm
19881989199019911992199319941995199619971998
} } if (bridge != null) { bridge.stop(); } } } private void testNoMaxBatchTime(final QualityOfServiceMode qosMode, final boolean persistent) throws Exception
20662067206820692070207120722073207420752076
finally { if (bridge != null) { JMSBridgeTest.log.info("Stopping bridge"); bridge.stop(); } } } private void testNoMaxBatchTimeSameServer(final QualityOfServiceMode qosMode, final boolean persistent) throws Exception