228229230231232233234235236237238
break; case 3: assertEquals("Second", message.getText()); assertTrue(message.getJMSRedelivered()); doneLatch.release(); break; default: errorMessage[0]="Got too many messages: "+counter; doneLatch.release();
233234235236237238239240241242243
doneLatch.release(); break; default: errorMessage[0]="Got too many messages: "+counter; doneLatch.release(); } } catch (Throwable e) { e.printStackTrace(); errorMessage[0]="Got exception: "+e; doneLatch.release();
238239240241242243244245246247248
doneLatch.release(); } } catch (Throwable e) { e.printStackTrace(); errorMessage[0]="Got exception: "+e; doneLatch.release(); } } }); connection.start();
382383384385386387388389390391392
} log.debug("Checkpoint done."); } finally { for (Iterator iter = listners.iterator(); iter.hasNext();) { Latch latch = (Latch) iter.next(); latch.release(); } } } });