[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