[hornetq-commits] JBoss hornetq SVN: r9495 - trunk/src/main/org/hornetq/core/persistence/impl/journal.
do-not-reply at jboss.org
do-not-reply at jboss.org
Mon Aug 2 23:23:01 EDT 2010
Author: clebert.suconic at 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
More information about the hornetq-commits
mailing list