mirror of https://github.com/apache/activemq.git
prevent npe
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@978813 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
f206a1bd11
commit
5f400b3853
|
@ -1009,8 +1009,8 @@ public class MessageDatabase extends ServiceSupport implements BrokerServiceAwar
|
||||||
MessageKeys keys = sd.orderIndex.remove(tx, sequenceId);
|
MessageKeys keys = sd.orderIndex.remove(tx, sequenceId);
|
||||||
if (keys != null) {
|
if (keys != null) {
|
||||||
sd.locationIndex.remove(tx, keys.location);
|
sd.locationIndex.remove(tx, keys.location);
|
||||||
}
|
recordAckMessageReferenceLocation(ackLocation, keys.location);
|
||||||
recordAckMessageReferenceLocation(ackLocation, keys.location);
|
}
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
// In the topic case we need remove the message once it's been acked
|
// In the topic case we need remove the message once it's been acked
|
||||||
|
|
Loading…
Reference in New Issue