[hornetq-commits] JBoss hornetq SVN: r11071 - branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl.

[do-not-reply at jboss.org]

Author: borges
Date: 2011-07-29 14:35:41 -0400 (Fri, 29 Jul 2011)
New Revision: 11071

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/JournalImpl.java
Log:
HORNETQ-720 Set value for the next file ID.

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-07-29 17:27:23 UTC (rev 11070)
+++ branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalFilesRepository.java	2011-07-29 18:35:41 UTC (rev 11071)
@@ -536,6 +536,11 @@
       return nextFileID.incrementAndGet();
    }
 
+   public void setNextFileID(long value)
+   {
+      nextFileID.set(value);
+   }
+
    /** Get the ID part of the name */
    private long getFileNameID(final String fileName)
    {

Modified: branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java	2011-07-29 17:27:23 UTC (rev 11070)
+++ branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java	2011-07-29 18:35:41 UTC (rev 11071)
@@ -3282,6 +3282,10 @@
             maxID = Math.max(maxID, id);
             filesRepository.createRemoteBackupSyncFile(id);
          }
+         if (maxID > 0)
+         {
+            filesRepository.setNextFileID(maxID);
+         }
       }
       finally
       {