[hornetq-commits] JBoss hornetq SVN: r11080 - branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl.
do-not-reply at jboss.org
do-not-reply at jboss.org
Mon Aug 1 06:30:13 EDT 2011
Author: borges
Date: 2011-08-01 06:30:12 -0400 (Mon, 01 Aug 2011)
New Revision: 11080
Modified:
branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalFilesRepository.java
Log:
HORNETQ-720 Initialize Map
Modified: branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalFilesRepository.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalFilesRepository.java 2011-08-01 09:35:28 UTC (rev 11079)
+++ branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalFilesRepository.java 2011-08-01 10:30:12 UTC (rev 11080)
@@ -14,6 +14,7 @@
package org.hornetq.core.journal.impl;
import java.util.Collection;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.BlockingDeque;
@@ -448,6 +449,10 @@
public void createRemoteBackupSyncFile(long fileID) throws Exception
{
+ if (filesReservedForSync == null)
+ {
+ filesReservedForSync = new HashMap<Long, JournalFile>();
+ }
assert !filesReservedForSync.containsKey(Long.valueOf(fileID));
filesReservedForSync.put(Long.valueOf(fileID), createFile(false, false, false, false, fileID));
}
More information about the hornetq-commits
mailing list