if (ServerManagement.isRemote()) return;
   public void cancelTest() throws Exception   {      MessageStore store = ServerManagement.getServerPeer().getMessageStore();            Connection conn = cf.createConnection();            Session sess = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);            MessageProducer prod = sess.createProducer(queue);            MessageConsumer cons = sess.createConsumer(queue);            conn.start();            TextMessage m1 = sess.createTextMessage("wibble");      TextMessage m2 = sess.createTextMessage("wibble");            prod.send(m1);      prod.send(m2);            TextMessage m3 = (TextMessage)cons.receive();            assertNotNull(m3);      assertEquals(m1.getText(), m3.getText());            TextMessage m4 = (TextMessage)cons.receive();            assertNotNull(m4);      assertEquals(m1.getText(), m4.getText());            sess.recover();            TextMessage m5 = (TextMessage)cons.receive();            assertNotNull(m5);      assertEquals(m1.getText(), m5.getText());            TextMessage m6 = (TextMessage)cons.receive();            assertNotNull(m6);      assertEquals(m1.getText(), m6.getText());             m6.acknowledge();            MessageReference ref = store.getReference(m2.getJMSMessageID());            assertNull(ref);   }