[hornetq-commits] JBoss hornetq SVN: r10470 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal.
do-not-reply at jboss.org
do-not-reply at jboss.org
Fri Apr 8 08:55:15 EDT 2011
Author: clebert.suconic at jboss.com
Date: 2011-04-08 08:55:14 -0400 (Fri, 08 Apr 2011)
New Revision: 10470
Modified:
branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
Log:
https://issues.jboss.org/browse/JBPAPP-6273 - just a little comment on the code
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java 2011-04-08 12:18:13 UTC (rev 10469)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java 2011-04-08 12:55:14 UTC (rev 10470)
@@ -1143,6 +1143,8 @@
continue;
}
+ // Redistribution could install a Redistributor while we are still loading records, what will be an issue with prepared ACKs
+ // We make sure te Queue is paused before we reroute values.
queue.pause();
Collection<AddMessageRecord> valueRecords = queueRecords.values();
More information about the hornetq-commits
mailing list