Author: clebert.suconic(a)jboss.com Date: 2010-08-12 16:18:00 -0400 (Thu, 12 Aug 2010) New Revision: 9535 Modified: trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java Log: HORNETQ-482 fixing typo Modified: trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java =================================================================== --- trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java 2010-08-12 19:39:55 UTC (rev 9534) +++ trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java 2010-08-12 20:18:00 UTC (rev 9535) @@ -1463,9 +1463,9 @@ private void checkDeleteSize() { // HORNETQ-482 - Flush deletes only if memory is critical - if (recordsToDelete.size() > DELETE_FLUSH && (runtime.freeMemory() > (runtime.maxMemory() * 0.8))) + if (recordsToDelete.size() > DELETE_FLUSH && (runtime.freeMemory() < (runtime.maxMemory() * 0.2))) { - log.debug("Flushing deletes during loading, deleteCount = " + recordsToDelete.size()); + log.info("Flushing deletes during loading, deleteCount = " + recordsToDelete.size()); // Clean up when the list is too large, or it won't be possible to load large sets of files // Done as part of JBMESSAGING-1678 Iterator<RecordInfo> iter = records.iterator(); @@ -1480,6 +1480,8 @@ } recordsToDelete.clear(); + + log.info("flush delete done"); } }