Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-4056 Expanding nextPage check into isDeleted

This commit is contained in:
Clebert Suconic 2022-10-18 11:51:47 -04:00
parent b388a24b26
commit 77ad2b0bc0
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
View File

@ -1508,7 +1508,8 @@ public final class PageSubscriptionImpl implements PageSubscription {
while (page <= pageStore.getCurrentWritingPage()) {
PageCursorInfo info = locatePageInfo(page);
if (info == null || info.getCompleteInfo() == null) {
// if pendingDelete or complete, we just move to next page
if (info == null || info.getCompleteInfo() == null && !info.isPendingDelete()) {
return page;
}
if (logger.isDebugEnabled()) {