[hornetq-commits] JBoss hornetq SVN: r10946 - branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl.

do-not-reply at jboss.org do-not-reply at jboss.org
Thu Jul 7 06:48:36 EDT 2011


Author: borges
Date: 2011-07-07 06:48:36 -0400 (Thu, 07 Jul 2011)
New Revision: 10946

Modified:
   branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java
Log:
Remove duplicated code.

Modified: branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java	2011-07-07 10:22:56 UTC (rev 10945)
+++ branches/HORNETQ-720_Replication/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java	2011-07-07 10:48:36 UTC (rev 10946)
@@ -2876,19 +2876,16 @@
    }
 
    /**
-    *
-    * @param completeTransaction If the appendRecord is for a prepare or commit, where we should update the number of pendingTransactions on the current file
-    * */
+    * @param completeTransaction If the appendRecord is for a prepare or commit, where we should
+    *           update the number of pendingTransactions on the current file
+    */
    private JournalFile appendRecord(final JournalInternalRecord encoder,
                                     final boolean completeTransaction,
                                     final boolean sync,
                                     final JournalTransaction tx,
                                     final IOAsyncTask parameterCallback) throws Exception
    {
-      if (state != JournalState.LOADED)
-      {
-         throw new IllegalStateException("The journal is not loaded " + state);
-      }
+      checkJournalIsLoaded();
 
       final IOAsyncTask callback;
 



More information about the hornetq-commits mailing list