break;

            }

         }

         return deleted;

      }

      finally

      {

               count++;

            }

         }

         return count;

      }

      finally

      {

               move(toAddress, tx, ref, false, rejectDuplicates);

               acknowledge(tx, ref);

            }

            return count;

         }

         finally

         {

      postOffice.route(copyMessage, tx, false, rejectDuplicate);

      acknowledge(tx, ref);

   }

   /*

    * This method delivers the reference on the callers thread - this can give us better latency in the case there is nothing in the queue

    */

 

               throw new HornetQXAException(XAException.XAER_PROTO, "Cannot commit transaction, it is suspended " + xid);

            }

            else

            {

            }

         }

      }

   }

         {

            if (XidImpl.toBase64String(xid).equals(transactionAsBase64))

            {

               Transaction transaction = resourceManager.removeTransaction(xid);

               long recordID = server.getStorageManager().storeHeuristicCompletion(xid, true);

               storageManager.waitOnOperations();

               resourceManager.putHeuristicCompletion(recordID, xid, true);

               return true;

            }

            cursor.ackTx(tx, msg);

         }

      }

      server.stop();

      OperationContextImpl.clearContext();

         assertEquals(i, msg.getMessage().getIntProperty("key").intValue());

         cursor.ackTx(tx, msg);

      }

      server.stop();

      createServer();

      waitCleanup();

      assertEquals(1, lookupPageStore(ADDRESS).getNumberOfPages());

                  }

                 

                  if (tx != null)

                  {

                  }

                 

               }

            }

            catch (Throwable e)

      assertNull(iterator.next());

      cursor.printDebug();

      txRollback.rollback();

     

      storage.waitOnOperations();