[hornetq-commits] JBoss hornetq SVN: r8946 - trunk/src/main/org/hornetq/core/persistence/impl/journal.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-03-22 19:43:26 -0400 (Mon, 22 Mar 2010)
New Revision: 8946

Modified:
   trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
Log:
no code changes on this commit. Just placing inner classes on their correct places

Modified: trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
===================================================================
--- trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java	2010-03-22 18:13:48 UTC (rev 8945)
+++ trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java	2010-03-22 23:43:26 UTC (rev 8946)
@@ -691,57 +691,6 @@
 
    }
 
-   private static final class AddMessageRecord
-   {
-      public AddMessageRecord(final ServerMessage message)
-      {
-         this.message = message;
-      }
-
-      final ServerMessage message;
-
-      long scheduledDeliveryTime;
-
-      int deliveryCount;
-   }
-
-   private class LargeMessageTXFailureCallback implements TransactionFailureCallback
-   {
-      private final Map<Long, ServerMessage> messages;
-
-      public LargeMessageTXFailureCallback(final Map<Long, ServerMessage> messages)
-      {
-         super();
-         this.messages = messages;
-      }
-
-      public void failedTransaction(final long transactionID,
-                                    final List<RecordInfo> records,
-                                    final List<RecordInfo> recordsToDelete)
-      {
-         for (RecordInfo record : records)
-         {
-            if (record.userRecordType == JournalStorageManager.ADD_LARGE_MESSAGE)
-            {
-               byte[] data = record.data;
-
-               HornetQBuffer buff = HornetQBuffers.wrappedBuffer(data);
-
-               try
-               {
-                  LargeServerMessage serverMessage = parseLargeMessage(messages, buff);
-                  serverMessage.decrementDelayDeletionCount();
-               }
-               catch (Exception e)
-               {
-                  JournalStorageManager.log.warn(e.getMessage(), e);
-               }
-            }
-         }
-      }
-
-   }
-
    public JournalLoadInformation loadMessageJournal(final PostOffice postOffice,
                                                     final PagingManager pagingManager,
                                                     final ResourceManager resourceManager,
@@ -2051,5 +2000,56 @@
       }
 
    }
+   private static final class AddMessageRecord
+   {
+      public AddMessageRecord(final ServerMessage message)
+      {
+         this.message = message;
+      }
 
+      final ServerMessage message;
+
+      long scheduledDeliveryTime;
+
+      int deliveryCount;
+   }
+
+   private class LargeMessageTXFailureCallback implements TransactionFailureCallback
+   {
+      private final Map<Long, ServerMessage> messages;
+
+      public LargeMessageTXFailureCallback(final Map<Long, ServerMessage> messages)
+      {
+         super();
+         this.messages = messages;
+      }
+
+      public void failedTransaction(final long transactionID,
+                                    final List<RecordInfo> records,
+                                    final List<RecordInfo> recordsToDelete)
+      {
+         for (RecordInfo record : records)
+         {
+            if (record.userRecordType == JournalStorageManager.ADD_LARGE_MESSAGE)
+            {
+               byte[] data = record.data;
+
+               HornetQBuffer buff = HornetQBuffers.wrappedBuffer(data);
+
+               try
+               {
+                  LargeServerMessage serverMessage = parseLargeMessage(messages, buff);
+                  serverMessage.decrementDelayDeletionCount();
+               }
+               catch (Exception e)
+               {
+                  JournalStorageManager.log.warn(e.getMessage(), e);
+               }
+            }
+         }
+      }
+
+   }
+
+
 }