11921193119411951196119711981199120012011202
refRemoved(ref); count++; } } tx.commit(); return count; } finally {
14191420142114221423142414251426142714281429
count++; move(toAddress, tx, ref, false, rejectDuplicates); acknowledge(tx, ref); } tx.commit(); return count; } finally {
20672068206920702071207220732074207520762077
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 */
863864865866867868869870871872873
deliveringCount.incrementAndGet(); acknowledge(tx, messageReference); count++; } tx.commit(); return count; } public synchronized boolean deleteReference(final long messageID) throws Exception
890891892893894895896897898899900
deleted = true; break; } } tx.commit(); return deleted; } public synchronized boolean expireReference(final long messageID) throws Exception
934935936937938939940941942943944
refRemoved(ref); count++; } } tx.commit(); return count; } public synchronized void expireReferences() throws Exception
10951096109710981099110011011102110311041105
count++; move(toAddress, tx, ref, false, rejectDuplicates); acknowledge(tx, ref); } tx.commit(); return count; } catch (Exception e) {
16031604160516061607160816091610161116121613
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 */
11001101110211031104110511061107110811091110
addTail(reference, false); } } } tx.commit(); if (filter != null && pageIterator != null) { scheduleDepage();
11401141114211431144114511461147114811491150
deleted = true; break; } } tx.commit(); return deleted; } finally {