12341235123612371238123912401241124212431244
bindings = office3.getAllBindings(); assertGotAll(3, bindings, queue1.getName()); office1.stop(); office2.stop(); office3.stop(); office1.start(); office2.start(); office3.start();
12651266126712681269127012711272127312741275
assertGotAll(2, bindings, queue1.getName()); bindings = office3.getAllBindings(); assertGotAll(3, bindings, queue1.getName()); office3.stop(); Thread.sleep(3000); bindings = office1.getAllBindings(); assertEquals(2, bindings.size());
13131314131513161317131813191320132113221323
if (office3 != null) { try { office3.stop(); } catch (Exception ignore) { } }
15161517151815191520152115221523152415251526
{ office1.removeBinding("queue1", true); office1.removeBinding("queue2", true); office1.removeBinding("queue3", true); office1.removeBinding("queue4", true); office1.stop(); } } } public void testBindSameName() throws Throwable
15771578157915801581158215831584158515861587
office1.stop(); } if (office2 != null) { office2.stop(); } } }
19401941194219431944194519461947194819491950
catch (Exception ignore) { ignore.printStackTrace(); } office2.stop(); } } } private void clusteredRouteWithFilter(boolean persistentMessage) throws Throwable
20472048204920502051205220532054205520562057
22062207220822092210221122122213221422152216
office3.stop(); } if (office4 != null) { office4.stop(); } } }
444445446447448449450451452453454
// Stop all offices office1.stop(); office2.stop(); office3.stop(); // Start them all office1.start(); office2.start(); office3.start();
599600601602603604605606607608609