[AMQ-8354] Update log messages.

amazon-mq · Oct 9, 2024 · d50696e · d50696e
1 parent bb01264
commit d50696e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...c/main/java/org/apache/activemq/replica/source/resync/ReplicaMessageRecoveryListener.java b/...c/main/java/org/apache/activemq/replica/source/resync/ReplicaMessageRecoveryListener.java
@@ -62,7 +62,7 @@ class ReplicaMessageRecoveryListener implements MessageRecoveryListener {
     @Override
     public boolean recoverMessage(Message message) throws Exception {
         if (++processedCount % 10000 == 0) {
-            logger.info("Progress: " + processedCount);
+            logger.info("Resynchronization progress: " + processedCount);
         }
 
         if (restoreMessageId != null && !foundMessage) {
@@ -88,7 +88,7 @@ public boolean recoverMessage(Message message) throws Exception {
             }
         } catch (Exception e) {
             broker.rollbackTransaction(connectionContext, tid);
-            logger.error("Failed", e);
+            logger.error("Failed to process next message", e);
             throw e;
         }
         return true;

diff --git a/...broker/src/main/java/org/apache/activemq/replica/source/resync/ReplicaResynchronizer.java b/...broker/src/main/java/org/apache/activemq/replica/source/resync/ReplicaResynchronizer.java
@@ -141,7 +141,7 @@ private void sendResetMessage(ConnectionContext connectionContext) throws Except
             broker.commitTransaction(connectionContext, tid, true);
         } catch (Exception e) {
             broker.rollbackTransaction(connectionContext, tid);
-            logger.error("Failed", e);
+            logger.error("Failed to send reset message", e);
             throw e;
         }
     }