[jboss-cvs] JBoss Messaging SVN: r4975 - in trunk/src/main/org/jboss/messaging/core/paging: impl and 1 other directory.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2008-09-17 16:27:12 -0400 (Wed, 17 Sep 2008)
New Revision: 4975

Modified:
   trunk/src/main/org/jboss/messaging/core/paging/PagingManager.java
   trunk/src/main/org/jboss/messaging/core/paging/impl/PagingManagerImpl.java
Log:
Removing a garbage method

Modified: trunk/src/main/org/jboss/messaging/core/paging/PagingManager.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/paging/PagingManager.java	2008-09-17 20:21:53 UTC (rev 4974)
+++ trunk/src/main/org/jboss/messaging/core/paging/PagingManager.java	2008-09-17 20:27:12 UTC (rev 4975)
@@ -99,12 +99,6 @@
    void addTransaction(PageTransactionInfo pageTransaction);
 
    /**
-    * Use this method to inform when a transaction was completed.
-    * @param transactionId
-    */
-   void completeTransaction(long transactionId);
-
-   /**
     * 
     * Duplication detection for paging processing
     *  */

Modified: trunk/src/main/org/jboss/messaging/core/paging/impl/PagingManagerImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/paging/impl/PagingManagerImpl.java	2008-09-17 20:21:53 UTC (rev 4974)
+++ trunk/src/main/org/jboss/messaging/core/paging/impl/PagingManagerImpl.java	2008-09-17 20:27:12 UTC (rev 4975)
@@ -320,18 +320,6 @@
       transactions.put(pageTransaction.getTransactionID(), pageTransaction);
    }
 
-   public void completeTransaction(final long transactionId)
-   {
-      PageTransactionInfo pageTrans = transactions.get(transactionId);
-
-      // If nothing was paged.. we just remove the information to avoid memory
-      // leaks
-      if (pageTrans.getNumberOfMessages() == 0)
-      {
-         transactions.remove(pageTrans);
-      }
-   }
-
    public void sync(final Collection<SimpleString> destinationsToSync) throws Exception
    {
       for (SimpleString destination : destinationsToSync)