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

Author: clebert.suconic(a)jboss.com Date: 2010-08-02 23:23:01 -0400 (Mon, 02 Aug 2010) New Revision: 9495 Modified: trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java Log: https://jira.jboss.org/browse/HORNETQ-468 - removing sync on deleteMessage Modified: trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java =================================================================== --- trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java 2010-08-03 02:42:47 UTC (rev 9494) +++ trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java 2010-08-03 03:23:01 UTC (rev 9495) @@ -511,7 +511,11 @@ public void deleteMessage(final long messageID) throws Exception { - messageJournal.appendDeleteRecord(messageID, syncNonTransactional, getContext(syncNonTransactional)); + // Messages are deleted on postACK, one after another. + // If these deletes are synchronized, we would build up messages on the Executor + // increasing chances of losing deletes. + // The StorageManager should verify messages without references + messageJournal.appendDeleteRecord(messageID, false, getContext(false)); } public void updateScheduledDeliveryTime(final MessageReference ref) throws Exception