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

    */

 

               }

            }

         }

        

        

         if (filter != null && pageIterator != null)

         {

            scheduleDepage();

               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

    */

 

            });

         }

      });

   }

  

   /* (non-Javadoc)

    * @see java.lang.Object#toString()

   {

      // Need to do the ACK and counter atomically (inside a TX) or the counter could get out of sync

      Transaction tx = new TransactionImpl(this.store);

      ackTx(tx, reference);

   }

   public void confirmPosition(final PagePosition position) throws Exception

   {

      // if we are dealing with a persistent cursor

            });

         }

      });

   }

   private PagedReference getReference(PagePosition pos) throws Exception

   {

   {

      // Need to do the ACK and counter atomically (inside a TX) or the counter could get out of sync

      Transaction tx = new TransactionImpl(this.store);

      ackTx(tx, reference);

   }

   public void confirmPosition(final PagePosition position) throws Exception

   {

      // if we are dealing with a persistent cursor