activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From djen...@apache.org
Subject svn commit: r730598 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/RecoveryListenerAdapter.java
Date Thu, 01 Jan 2009 20:18:09 GMT
Author: djencks
Date: Thu Jan  1 12:18:08 2009
New Revision: 730598

URL: http://svn.apache.org/viewvc?rev=730598&view=rev
Log:
AMQ-2052 Throw an exception when references to non-existent messages are encountered

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/RecoveryListenerAdapter.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/RecoveryListenerAdapter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/RecoveryListenerAdapter.java?rev=730598&r1=730597&r2=730598&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/RecoveryListenerAdapter.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/RecoveryListenerAdapter.java
Thu Jan  1 12:18:08 2009
@@ -55,9 +55,8 @@
         if (message != null) {
             return recoverMessage(message);
         } else {
-            LOG.error("Message id " + ref + " could not be recovered from the data store
- already dispatched");
+            throw new IllegalStateException("Message id " + ref + " could not be recovered
from the data store - already dispatched");
         }
-        return false;
     }
 
     MessageId getLastRecoveredMessageId() {



Mime
View raw message