[hornetq-commits] JBoss hornetq SVN: r9267 - trunk/src/main/org/hornetq/core/persistence/impl/journal.
Author: clebert.suconic(a)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: