ms = new PagingMessageStore("shared-in-memory-store");
ms = new SimpleMessageStore("shared-in-memory-store");
   public void setUp() throws Exception   {      super.setUp();      ms = new PagingMessageStore("shared-in-memory-store");      jchannel = new JChannel(JGroupsUtil.generateProperties(50, 1));      jchannel2 = new JChannel(JGroupsUtil.generateProperties(900000, 1));      jchannel3 = new JChannel(JGroupsUtil.generateProperties(900000, 2));      dispatcher = new RpcDispatcher(jchannel, null, null, new RpcServer("1"));      dispatcher2 = new RpcDispatcher(jchannel2, null, null, new RpcServer("2"));      dispatcher3 = new RpcDispatcher(jchannel3, null, null, new RpcServer("3"));      distributed = createDistributed("test", ms, dispatcher);      distributed2 = createDistributed("test", ms, dispatcher2);      distributed3 = createDistributed("test", ms, dispatcher3);      peer = distributed.getPeer();      peer2 = distributed2.getPeer();      peer3 = distributed3.getPeer();      // connect only the first JChannel      jchannel.connect("testGroup");      assertEquals(1, jchannel.getView().getMembers().size());   }