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

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2008-07-14 12:47:22 -0400 (Mon, 14 Jul 2008)
New Revision: 4683

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

Modified: trunk/src/main/org/jboss/messaging/core/persistence/impl/journal/JournalStorageManager.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/persistence/impl/journal/JournalStorageManager.java	2008-07-14 16:10:52 UTC (rev 4682)
+++ trunk/src/main/org/jboss/messaging/core/persistence/impl/journal/JournalStorageManager.java	2008-07-14 16:47:22 UTC (rev 4683)
@@ -604,7 +604,27 @@
 	
 	private EncodingSupport ackBytes(final long queueID, final long messageID)
    {
-      return new ACKRecord(queueID, messageID);
+	   // Using an EncodingSupport, to avoid some byteArrayCopy
+      return new EncodingSupport()
+      {
+
+         public void decode(MessagingBuffer buffer)
+         {
+            throw new UnsupportedOperationException();
+         }
+
+         public void encode(MessagingBuffer buffer)
+         {
+            buffer.putLong(queueID);
+            buffer.putLong(messageID);
+         }
+
+         public int getEncodeSize()
+         {
+            return SIZE_LONG * 2;
+         }
+       
+      };
    }
 	
 	private void checkAndCreateDir(String dir, boolean create)
@@ -639,37 +659,4 @@
 	
    // Inner Classes ----------------------------------------------------------------------------
 
-	class ACKRecord implements EncodingSupport
-   {
-      private long queueID;
-      private long messageID;
-      
-      
-
-      public ACKRecord(long queueID, long messageID)
-      {
-         super();
-         this.queueID = queueID;
-         this.messageID = messageID;
-      }
-
-      public void decode(MessagingBuffer buffer)
-      {
-         throw new UnsupportedOperationException();
-      }
-
-      public void encode(MessagingBuffer buffer)
-      {
-         buffer.putLong(queueID);
-         buffer.putLong(messageID);
-      }
-
-      public int getEncodeSize()
-      {
-         return SIZE_LONG * 2;
-      }
-      
-   }
-   
-
 }