Author: clebert.suconic(a)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);
Show replies by date