[jboss-cvs] JBoss Messaging SVN: r5718 - trunk/src/main/org/jboss/messaging/core/persistence/impl/journal.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Sun Jan 25 00:41:14 EST 2009


Author: clebert.suconic at jboss.com
Date: 2009-01-25 00:41:14 -0500 (Sun, 25 Jan 2009)
New Revision: 5718

Modified:
   trunk/src/main/org/jboss/messaging/core/persistence/impl/journal/JournalLargeServerMessage.java
Log:
tweak

Modified: trunk/src/main/org/jboss/messaging/core/persistence/impl/journal/JournalLargeServerMessage.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/persistence/impl/journal/JournalLargeServerMessage.java	2009-01-25 05:39:20 UTC (rev 5717)
+++ trunk/src/main/org/jboss/messaging/core/persistence/impl/journal/JournalLargeServerMessage.java	2009-01-25 05:41:14 UTC (rev 5718)
@@ -71,13 +71,19 @@
       this.storageManager = storageManager;
    }
 
-   public JournalLargeServerMessage(final JournalLargeServerMessage copy, final SequentialFile fileCopy)
+   /**
+    * Copy constructor
+    * @param copy
+    * @param fileCopy
+    */
+   private JournalLargeServerMessage(final JournalLargeServerMessage copy, final SequentialFile fileCopy, final long newID)
    {
       super(copy);
       this.storageManager = copy.storageManager;
       this.file = fileCopy;
       this.complete = true;
       this.bodySize = copy.bodySize;
+      this.setMessageID(newID);
    }
 
    // Public --------------------------------------------------------
@@ -273,8 +279,7 @@
       file.close();
       newfile.close();
       
-      JournalLargeServerMessage newMessage = new JournalLargeServerMessage(this, newfile);
-      newMessage.setMessageID(newID);
+      JournalLargeServerMessage newMessage = new JournalLargeServerMessage(this, newfile, newID);
       
       return newMessage;
    }




More information about the jboss-cvs-commits mailing list