232233234235236237238239240241242
manager.stop(); } finally { server.stop(); } } public void testSendPackets() throws Exception {
332333334335336337338339340341342
manager.stop(); } finally { server.stop(); } } public void testSendPacketsWithFailure() throws Exception {
384385386387388389390391392393394
{ latch.countDown(); } }); server.stop(); Assert.assertTrue(latch.await(50, TimeUnit.SECONDS)); } finally {
390391392393394395396397398399400
Assert.assertTrue(latch.await(50, TimeUnit.SECONDS)); } finally { server.stop(); } } public void testExceptionSettingActionBefore() throws Exception {
566567568569570571572573574575576
Assert.assertEquals(0, manager.getActiveTokens().size()); manager.stop(); } finally { server.stop(); } } public void testOrderOnNonPersistency() throws Exception {
636637638639640641642643644645646
Assert.assertEquals(0, manager.getActiveTokens().size()); manager.stop(); } finally { server.stop(); } } class FakeData implements EncodingSupport {