From 9dc3f7d95edcec19496236b6ed7f6ce4b1071e8d Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Fri, 6 Apr 2007 10:55:17 +0000 Subject: git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@526118 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpid/server/txn/CleanupMessageOperation.java | 13 +------------ 1 file changed, 1 insertion(+), 12 deletions(-) (limited to 'java/broker/src') diff --git a/java/broker/src/main/java/org/apache/qpid/server/txn/CleanupMessageOperation.java b/java/broker/src/main/java/org/apache/qpid/server/txn/CleanupMessageOperation.java index 05d1cd5291..609a85c22f 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/txn/CleanupMessageOperation.java +++ b/java/broker/src/main/java/org/apache/qpid/server/txn/CleanupMessageOperation.java @@ -56,18 +56,7 @@ public class CleanupMessageOperation implements TxnOp public void commit(StoreContext context) { - //The routers reference can now be released. This is done - //here to ensure that it happens after the queues that - //enqueue it have incremented their counts (which as a - //memory only operation is done in the commit phase). - try - { - _msg.decrementReference(context); - } - catch (AMQException e) - { - _log.error("On commiting transaction, failed to cleanup unused message: " + e, e); - } + try { _msg.checkDeliveredToConsumer(); -- cgit v1.2.1