13211322132313241325132613271328132913301331
deleted = true; break; } } tx.commit(); return deleted; } finally {
14421443144414451446144714481449145014511452
refRemoved(ref); count++; } } tx.commit(); return count; } finally {
23612362236323642365236623672368236923702371
postOffice.route(copyMessage, tx, false, rejectDuplicate); 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 */
11881189119011911192119311941195119611971198
} } if (txCount > 0) { tx.commit(); tx = new TransactionImpl(storageManager); txCount = 0; }
12051206120712081209121012111212121312141215
txCount++; } if (txCount > 0) { tx.commit(); tx = new TransactionImpl(storageManager); txCount = 0; }
12321233123412351236123712381239124012411242
addTail(reference, false); } if (txCount > 0 && txCount % 500 == 0) { tx.commit(); tx = new TransactionImpl(storageManager); txCount = 0; } } }
12411242124312441245124612471248124912501251
} } if (txCount > 0) { tx.commit(); tx = null; }
12941295129612971298129913001301130213031304
14041405140614071408140914101411141214131414
23232324232523262327232823292330233123322333