[hornetq-commits] JBoss hornetq SVN: r8373 - branches/ClebertCallback/src/main/org/hornetq/core/journal/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-11-22 23:43:08 -0500 (Sun, 22 Nov 2009)
New Revision: 8373

Modified:
   branches/ClebertCallback/src/main/org/hornetq/core/journal/impl/JournalImpl.java
Log:
tweak

Modified: branches/ClebertCallback/src/main/org/hornetq/core/journal/impl/JournalImpl.java
===================================================================
--- branches/ClebertCallback/src/main/org/hornetq/core/journal/impl/JournalImpl.java	2009-11-23 03:38:18 UTC (rev 8372)
+++ branches/ClebertCallback/src/main/org/hornetq/core/journal/impl/JournalImpl.java	2009-11-23 04:43:08 UTC (rev 8373)
@@ -943,11 +943,6 @@
          throw new IllegalStateException("Journal must be loaded first");
       }
       
-      if (callback != null)
-      {
-         callback.lineUp();
-      }
-
       compactingLock.readLock().lock();
 
       try
@@ -963,6 +958,11 @@
             }
          }
 
+         if (callback != null)
+         {
+            callback.lineUp();
+         }
+
          int size = SIZE_UPDATE_RECORD + record.getEncodeSize();
 
          ChannelBuffer bb = newBuffer(size);