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() {
