refs[i].incrementChannelCount(); refs[i].decrementChannelCount();
refs[i].releaseMemoryReference();
   public void testRecoverableMessageStore_2() throws Exception   {      if (!ms.isRecoverable())      {         // we only test recoverable message stores         return;      }      Message[] m = new Message[NUMBER_OF_MESSAGES];      MessageReference[] refs = new MessageReference[NUMBER_OF_MESSAGES];      for(int i = 0; i < NUMBER_OF_MESSAGES; i++ )      {         m[i] = MessageFactory.createCoreMessage(i, false, 700 + i, 800 + i,                                             (byte)(i % 10), headers, "payload" + i);         // recoverable store, non-reliable message, one message         refs[i] = ms.reference(m[i]);         assertCorrectReference(refs[i], ms.getStoreID(), m[i]);      }      // get reachable reference      for (int i = 0; i < NUMBER_OF_MESSAGES; i++)      {                  assertCorrectReference(refs[i], ms.getStoreID(), m[i]);         refs[i].incrementChannelCount();         refs[i].decrementChannelCount();      }      for (int i = 0; i < NUMBER_OF_MESSAGES; i++)      {         assertNull(ms.reference(m[i].getMessageID()));      }   }