mirror of https://github.com/apache/activemq.git
AMQ-2052 Throw an exception when references to non-existent messages are encountered
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@730598 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
13d692ebde
commit
f27bd3c491
|
@ -55,9 +55,8 @@ final class RecoveryListenerAdapter implements MessageRecoveryListener {
|
|||
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() {
|
||||
|
|
Loading…
Reference in New Issue