state.remove(deliveries[i], tx);
state.acknowledge(deliveries[i], tx);
   public void testNonRecoverableState_14() throws Throwable   {      if (state.isRecoverable())      {         // only non-recoverable state is tested now         return;      }      if (state.acceptReliableMessages())      {         // only state that does not accept reliable messages is tested now         return;      }      MessageReference[] refs = new MessageReference[NUMBER_OF_MESSAGES];      Delivery[] deliveries = new Delivery[NUMBER_OF_MESSAGES];      for(int i = 0; i < NUMBER_OF_MESSAGES; i++)      {         refs[i] =  ms.reference(MessageFactory.createMessage("message" + i, false, "payload" + i));         deliveries[i] = new SimpleDelivery(channel, refs[i], false);         state.add(deliveries[i]);      }      Transaction tx = tr.createTransaction();      for(int i = 0; i < NUMBER_OF_MESSAGES; i++)      {         // non-recoverable state, unreliable delivery, transactional remove         state.remove(deliveries[i], tx);      }      tx.rollback();      ChannelTestBase.assertEqualSets(refs, state.delivering(null));      assertTrue(state.undelivered(null).isEmpty());      ChannelTestBase.assertEqualSets(refs, state.browse(null));      log.info("ok");   }