LocalClusteredQueue queue2 = new LocalClusteredQueue(office3, "node3", "queue1", im.getId(), ms, pm, true, false, (QueuedExecutor)pool.get(), null, tr);
LocalClusteredQueue queue2 = new LocalClusteredQueue(office3, 3, "queue1", im.getId(), ms, pm, true, false, (QueuedExecutor)pool.get(), null, tr);
   protected void local(boolean persistent) throws Throwable   {      ClusteredPostOffice office1 = null;            ClusteredPostOffice office2 = null;            ClusteredPostOffice office3 = null;            ClusteredPostOffice office4 = null;            ClusteredPostOffice office5 = null;            ClusteredPostOffice office6 = null;                try      {            office1 = createClusteredPostOffice("node1", "testgroup");                  office2 = createClusteredPostOffice("node2", "testgroup");                  office3 = createClusteredPostOffice("node3", "testgroup");                  office4 = createClusteredPostOffice("node4", "testgroup");                  office5 = createClusteredPostOffice("node5", "testgroup");                  office6 = createClusteredPostOffice("node6", "testgroup");                  LocalClusteredQueue queue1 = new LocalClusteredQueue(office2, "node2", "queue1", im.getId(), ms, pm, true, false, (QueuedExecutor)pool.get(), null, tr);                  Binding binding1 = office2.bindClusteredQueue("topic", queue1);         SimpleReceiver receiver1 = new SimpleReceiver("blah", SimpleReceiver.ACCEPTING);         queue1.add(receiver1);                  LocalClusteredQueue queue2 = new LocalClusteredQueue(office3, "node3", "queue1", im.getId(), ms, pm, true, false, (QueuedExecutor)pool.get(), null, tr);                  Binding binding2 = office3.bindClusteredQueue("topic", queue2);         SimpleReceiver receiver2 = new SimpleReceiver("blah", SimpleReceiver.ACCEPTING);         queue2.add(receiver2);                  LocalClusteredQueue queue3 = new LocalClusteredQueue(office4, "node4", "queue1", im.getId(), ms, pm, true, false, (QueuedExecutor)pool.get(), null, tr);                  Binding binding3 = office4.bindClusteredQueue("topic", queue3);         SimpleReceiver receiver3 = new SimpleReceiver("blah", SimpleReceiver.ACCEPTING);         queue3.add(receiver3);                  LocalClusteredQueue queue4 = new LocalClusteredQueue(office5, "node5", "queue1", im.getId(), ms, pm, true, false, (QueuedExecutor)pool.get(), null, tr);                  Binding binding4 = office5.bindClusteredQueue("topic", queue4);         SimpleReceiver receiver4 = new SimpleReceiver("blah", SimpleReceiver.ACCEPTING);         queue4.add(receiver4);                  LocalClusteredQueue queue5 = new LocalClusteredQueue(office6, "node6", "queue1", im.getId(), ms, pm, true, false, (QueuedExecutor)pool.get(), null, tr);                  Binding binding5 = office6.bindClusteredQueue("topic", queue5);         SimpleReceiver receiver5 = new SimpleReceiver("blah", SimpleReceiver.ACCEPTING);         queue5.add(receiver5);                        List msgs = sendMessages("topic", persistent, office2, 3, null);                  checkContainsAndAcknowledge(msgs, receiver1, queue1);                  checkEmpty(receiver2);         checkEmpty(receiver3);         checkEmpty(receiver4);         checkEmpty(receiver5);                  msgs = sendMessages("topic", persistent, office2, 3, null);                  checkContainsAndAcknowledge(msgs, receiver1, queue1);                  checkEmpty(receiver2);         checkEmpty(receiver3);         checkEmpty(receiver4);         checkEmpty(receiver5);                  msgs = sendMessages("topic", persistent, office2, 3, null);                  checkContainsAndAcknowledge(msgs, receiver1, queue1);                  checkEmpty(receiver2);         checkEmpty(receiver3);         checkEmpty(receiver4);         checkEmpty(receiver5);                           msgs = sendMessages("topic", persistent, office3, 3, null);          checkEmpty(receiver1);         checkContainsAndAcknowledge(msgs, receiver2, queue1);                           checkEmpty(receiver3);         checkEmpty(receiver4);         checkEmpty(receiver5);                  msgs = sendMessages("topic", persistent, office3, 3, null);          checkEmpty(receiver1);         checkContainsAndAcknowledge(msgs, receiver2, queue1);                           checkEmpty(receiver3);         checkEmpty(receiver4);         checkEmpty(receiver5);                  msgs = sendMessages("topic", persistent, office3, 3, null);          checkEmpty(receiver1);         checkContainsAndAcknowledge(msgs, receiver2, queue1);                           checkEmpty(receiver3);         checkEmpty(receiver4);         checkEmpty(receiver5);                                    }      finally      {         if (office1 != null)         {                        office1.stop();         }                  if (office2 != null)         {            office2.stop();         }                  if (office3 != null)         {                        office3.stop();         }                  if (office4 != null)         {            office4.stop();         }                  if (office5 != null)         {                        office5.stop();         }                  if (office6 != null)         {            office6.stop();         }      }   }