25202521252225232524252525262527252825292530
} } ClientSession session = sendAndConsume(sf, true); session.addFailureListener(new MyListener()); backupServer.stop(); liveServer.crash();
25742575257625772578257925802581258225832584
26302631263226332634263526362637263826392640
27022703270427052706270727082709271027112712
8687888990919293949596
System.out.println(locator.getTopology().describe()); MyListener listener = new MyListener(latch); session.addFailureListener(listener); System.out.println(locator.getTopology().describe()); liveServer.crash();
117118119120121122123124125126127
final CountDownLatch latch2 = new CountDownLatch(1); listener = new MyListener(latch2); session.addFailureListener(listener); log.info("******* starting live server back"); liveServer.start(); Thread.sleep(1000);
181182183184185186187188189190191
ClientSession session = sendAndConsume(sf, true); MyListener listener = new MyListener(latch); session.addFailureListener(listener); liveServer.crash(); assertTrue(latch.await(5, TimeUnit.SECONDS));
201202203204205206207208209210211
CountDownLatch latch2 = new CountDownLatch(1); listener = new MyListener(latch2); session.addFailureListener(listener); log.info("restarting live node now"); liveServer.start(); assertTrue(latch2.await(5, TimeUnit.SECONDS));
220221222223224225226227228229230
session.removeFailureListener(listener); listener = new MyListener(latch3); session.addFailureListener(listener); waitForBackup(sf, 10); liveServer.crash();
411412413414415416417418419420421
} } continue; } cs.addFailureListener(this); synchronized (HornetQXAResourceWrapper.lock) { delegate = cs; }