[hornetq-commits] JBoss hornetq SVN: r8440 - trunk/src/main/org/hornetq/core/persistence/impl/journal.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-11-27 22:29:29 -0500 (Fri, 27 Nov 2009)
New Revision: 8440

Modified:
   trunk/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java
Log:
Tweak... There's always an executor on the context now.. Removing one extra check that is not necessary

Modified: trunk/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java	2009-11-28 03:15:46 UTC (rev 8439)
+++ trunk/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java	2009-11-28 03:29:29 UTC (rev 8440)
@@ -176,23 +176,14 @@
             TaskHolder holder = iter.next();
             if (stored >= holder.storeLined && replicated >= holder.replicationLined)
             {
-               if (executor != null)
-               {
-                  // If set, we use an executor to avoid the server being single threaded
-                  execute(holder.task);
-               }
-               else
-               {
-                  holder.task.done();
-               }
+               // If set, we use an executor to avoid the server being single threaded
+               execute(holder.task);
 
                iter.remove();
             }
             else
             {
-               // The actions need to be done in order...
-               // And they are added in order...
-               // As soon as we're done, we break the loop
+               // End of list here. No other task will be completed after this
                break;
             }
          }