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

NO-JIRA Update Paging Logging with extra information

This commit is contained in:
Clebert Suconic 2021-09-24 13:16:56 -04:00
parent ef677d14d4
commit e4276e8cd0
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -920,7 +920,10 @@ public final class PageSubscriptionImpl implements PageSubscription {
}
if (cache == null || pos.getMessageNr() >= 0 && cache.getMessage(pos) == null) {
ActiveMQServerLogger.LOGGER.pageNotFound(pos);
try {
ActiveMQServerLogger.LOGGER.pageNotFound(pos, this.cursorId, this.queue.getName().toString());
} catch (Throwable ignored) {
}
if (txDeleteCursorOnReload == -1) {
txDeleteCursorOnReload = store.generateID();
}

4
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java
View File

@ -571,9 +571,9 @@ public interface ActiveMQServerLogger extends BasicLogger {
void timedOutFlushingExecutorsPagingCursor(PageSubscription pageSubscription);
@LogMessage(level = Logger.Level.WARN)
@Message(id = 222028, value = "Could not find page cache for page {0} removing it from the journal",
@Message(id = 222028, value = "Could not find page cache for page {0}, on queue {1}/{2} removing it from the journal",
format = Message.Format.MESSAGE_FORMAT)
void pageNotFound(PagePosition pos);
void pageNotFound(PagePosition pos, long queueID, String queue);
@LogMessage(level = Logger.Level.WARN)
@Message(id = 222029,