LocalClusteredQueue queue1 = new LocalClusteredQueue(office1, 1, "queue1", im.getId(), ms, pm, true, false, (QueuedExecutor)pool.get(), filter1, tr);
LocalClusteredQueue queue1 = new LocalClusteredQueue(office1, 1, "queue1", channelIdManager.getId(), ms, pm, true, recoverable, (QueuedExecutor)pool.get(), filter1, tr);
   protected void clusteredRouteWithFilter(boolean persistentMessage) throws Throwable   {      ClusteredPostOffice office1 = null;            ClusteredPostOffice office2 = null;                try      {            office1 = createClusteredPostOffice(1, "testgroup");         office2 = createClusteredPostOffice(2, "testgroup");                  SimpleFilter filter1 = new SimpleFilter(2);         SimpleFilter filter2 = new SimpleFilter(3);               LocalClusteredQueue queue1 = new LocalClusteredQueue(office1, 1, "queue1", im.getId(), ms, pm, true, false, (QueuedExecutor)pool.get(), filter1, tr);                  Binding binding1 =            office1.bindClusteredQueue("topic1", queue1);                  LocalClusteredQueue queue2 = new LocalClusteredQueue(office2, 2, "queue2", im.getId(), ms, pm, true, false, (QueuedExecutor)pool.get(), filter2, tr);                  Binding binding2 =            office2.bindClusteredQueue("topic1", queue2);                  LocalClusteredQueue queue3 = new LocalClusteredQueue(office2, 2, "queue3", im.getId(), ms, pm, true, false, (QueuedExecutor)pool.get(), null, tr);                  Binding binding3 =            office2.bindClusteredQueue("topic1", queue3);                     SimpleReceiver receiver1 = new SimpleReceiver("blah", SimpleReceiver.ACCEPTING);         queue1.add(receiver1);         SimpleReceiver receiver2 = new SimpleReceiver("blah", SimpleReceiver.ACCEPTING);         queue2.add(receiver2);         SimpleReceiver receiver3 = new SimpleReceiver("blah", SimpleReceiver.ACCEPTING);         queue3.add(receiver3);                  Message msg1 = CoreMessageFactory.createCoreMessage(1);               MessageReference ref1 = ms.reference(msg1);           log.info("Sending message 1");         boolean routed = office1.route(ref1, "topic1", null);            log.info("Sent message 1");         assertTrue(routed);                           Message msg2 = CoreMessageFactory.createCoreMessage(2);               MessageReference ref2 = ms.reference(msg2);                  routed = office1.route(ref2, "topic1", null);               assertTrue(routed);         Message msg3 = CoreMessageFactory.createCoreMessage(3);               MessageReference ref3 = ms.reference(msg3);                  routed = office1.route(ref3, "topic1", null);               assertTrue(routed);                  Thread.sleep(1000);                  List msgs = receiver1.getMessages();         assertNotNull(msgs);         assertEquals(1, msgs.size());         Message msgRec = (Message)msgs.get(0);         assertTrue(msg2 == msgRec);         receiver1.acknowledge(msgRec, null);         msgs = queue1.browse();         assertNotNull(msgs);         assertTrue(msgs.isEmpty());                    msgs = receiver2.getMessages();         assertNotNull(msgs);         assertEquals(1, msgs.size());         msgRec = (Message)msgs.get(0);         assertTrue(msg3 == msgRec);         receiver2.acknowledge(msgRec, null);         msgs = queue2.browse();         assertNotNull(msgs);         assertTrue(msgs.isEmpty());                    msgs = receiver3.getMessages();         assertNotNull(msgs);         assertEquals(3, msgs.size());         Message msgRec1 = (Message)msgs.get(0);         assertTrue(msg1 == msgRec1);         Message msgRec2 = (Message)msgs.get(1);         assertTrue(msg2 == msgRec2);         Message msgRec3 = (Message)msgs.get(2);         assertTrue(msg3 == msgRec3);                   receiver3.acknowledge(msgRec1, null);         receiver3.acknowledge(msgRec2, null);         receiver3.acknowledge(msgRec3, null);         msgs = queue3.browse();         assertNotNull(msgs);         assertTrue(msgs.isEmpty());                }      finally      {         if (office1 != null)         {            office1.stop();         }                  if (office2 != null)         {            office2.stop();         }                  checkNoMessageData();      }   }