NO-JIRA Update Paging Logging with extra information

apache · Sep 24, 2021 · e4276e8 · e4276e8
1 parent ef677d1
commit e4276e8
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/...c/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java b/...c/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
@@ -920,7 +920,10 @@ public void processReload() throws Exception {
             }
 
             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();
                }

diff --git a/...is-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java b/...is-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java
@@ -571,9 +571,9 @@ void slowConsumerDetected(String sessionID,
    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,