svn commit: r526118 - /incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/txn/CleanupMessageOperation.java

[rg...@apache.org]

Author: rgodfrey
Date: Fri Apr  6 03:55:17 2007
New Revision: 526118

URL: http://svn.apache.org/viewvc?view=rev&rev=526118
Log: (empty)

Modified:
    incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/txn/CleanupMessageOperation.java

Modified: incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/txn/CleanupMessageOperation.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/txn/CleanupMessageOperation.java?view=diff&rev=526118&r1=526117&r2=526118
==============================================================================
--- incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/txn/CleanupMessageOperation.java (original)
+++ incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/txn/CleanupMessageOperation.java Fri Apr  6 03:55:17 2007
@@ -56,18 +56,7 @@
 
     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();