[hornetq-commits] JBoss hornetq SVN: r8143 - trunk/src/main/org/hornetq/core/persistence/impl/journal.
do-not-reply at jboss.org
do-not-reply at jboss.org
Mon Oct 26 18:16:18 EDT 2009
Author: clebert.suconic at jboss.com
Date: 2009-10-26 18:16:17 -0400 (Mon, 26 Oct 2009)
New Revision: 8143
Modified:
trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalLargeServerMessage.java
Log:
Removing file.open left by accident
Modified: trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalLargeServerMessage.java
===================================================================
--- trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalLargeServerMessage.java 2009-10-26 09:04:15 UTC (rev 8142)
+++ trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalLargeServerMessage.java 2009-10-26 22:16:17 UTC (rev 8143)
@@ -287,6 +287,7 @@
@Override
public synchronized ServerMessage copy(final long newID) throws Exception
{
+ // Incrementing the reference counting to avoid deletion of the linkedMessage
incrementRefCount();
long idToUse = messageID;
@@ -298,8 +299,6 @@
SequentialFile newfile = storageManager.createFileForLargeMessage(idToUse, isStored());
- file.open();
-
JournalLargeServerMessage newMessage = new JournalLargeServerMessage(linkMessage == null ? this : (JournalLargeServerMessage)linkMessage, newfile, newID);
return newMessage;
More information about the hornetq-commits
mailing list