856857858859860861862863864865866
deliveringCount.incrementAndGet(); acknowledge(tx, messageReference); count++; } tx.commit(); return count; } public synchronized boolean deleteReference(final long messageID) throws Exception
883884885886887888889890891892893
deleted = true; break; } } tx.commit(); return deleted; } public synchronized boolean expireReference(final long messageID) throws Exception
927928929930931932933934935936937
refRemoved(ref); count++; } } tx.commit(); return count; } public synchronized void expireReferences() throws Exception
10881089109010911092109310941095109610971098
count++; move(toAddress, tx, ref, false, rejectDuplicates); acknowledge(tx, ref); } tx.commit(); return count; } catch (Exception e) {
15961597159815991600160116021603160416051606
postOffice.route(copyMessage, tx, false); acknowledge(tx, ref); tx.commit(); } /* * This method delivers the reference on the callers thread - this can give us better latency in the case there is nothing in the queue */
11541155115611571158115911601161116211631164
} } if (txCount > 0) { tx.commit(); tx = new TransactionImpl(storageManager); txCount = 0; }
11711172117311741175117611771178117911801181
txCount++; } if (txCount > 0) { tx.commit(); tx = new TransactionImpl(storageManager); txCount = 0; }
11981199120012011202120312041205120612071208
addTail(reference, false); } if (txCount > 0 && txCount % 500 == 0) { tx.commit(); tx = new TransactionImpl(storageManager); txCount = 0; } } }
12071208120912101211121212131214121512161217
} } if (txCount > 0) { tx.commit(); tx = null; }
12601261126212631264126512661267126812691270
deleted = true; break; } } tx.commit(); return deleted; } finally {