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

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-05-26 10:36:21 -0400 (Wed, 26 May 2010)
New Revision: 9267

Modified:
   trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
Log:
https://jira.jboss.org/browse/HORNETQ-394 - changing a critical error to a warning on update counts

Modified: trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
===================================================================
--- trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java	2010-05-26 11:50:26 UTC (rev 9266)
+++ trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java	2010-05-26 14:36:21 UTC (rev 9267)
@@ -871,18 +871,20 @@
 
                if (queueMessages == null)
                {
-                  throw new IllegalStateException("Cannot find queue messages " + encoding.queueID);
+                  log.warn("Cannot find queue "  + encoding.queueID + " to update delivery count");
                }
-
-               AddMessageRecord rec = queueMessages.get(messageID);
-
-               if (rec == null)
+               else
                {
-                  throw new IllegalStateException("Cannot find message " + messageID);
+                  AddMessageRecord rec = queueMessages.get(messageID);
+   
+                  if (rec == null)
+                  {
+                     throw new IllegalStateException("Cannot find message " + messageID);
+                  }
+   
+                  rec.deliveryCount = encoding.count;
                }
 
-               rec.deliveryCount = encoding.count;
-
                break;
             }
             case PAGE_TRANSACTION: