mirror of
https://github.com/apache/activemq-artemis.git
synced 2025-03-06 17:30:11 +00:00
This closes #2445
This commit is contained in:
commit
3a0491b920
@ -473,11 +473,10 @@ public class PageCursorProviderImpl implements PageCursorProvider {
|
|||||||
}
|
}
|
||||||
|
|
||||||
depagedPage.delete(pgdMessages);
|
depagedPage.delete(pgdMessages);
|
||||||
onDeletePage(depagedPage);
|
|
||||||
|
|
||||||
synchronized (softCache) {
|
synchronized (softCache) {
|
||||||
softCache.remove((long) depagedPage.getPageId());
|
softCache.remove((long) depagedPage.getPageId());
|
||||||
}
|
}
|
||||||
|
onDeletePage(depagedPage);
|
||||||
}
|
}
|
||||||
} catch (Exception ex) {
|
} catch (Exception ex) {
|
||||||
ActiveMQServerLogger.LOGGER.problemCleaningPageAddress(ex, pagingStore.getAddress());
|
ActiveMQServerLogger.LOGGER.problemCleaningPageAddress(ex, pagingStore.getAddress());
|
||||||
|
Loading…
x
Reference in New Issue
Block a user