[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