activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject activemq git commit: https://issues.apache.org/jira/browse/AMQ-6071 - Log info about corrupted journal records at WARN level
Date Fri, 04 Dec 2015 20:24:10 GMT
Repository: activemq
Updated Branches:
  refs/heads/activemq-5.13.x e1cf0d267 -> 11ebaccd6


https://issues.apache.org/jira/browse/AMQ-6071 - Log info about corrupted journal records
at WARN level

(cherry picked from commit 66c348b1b85e341ed508b9c10028c037a226dfb6)


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/11ebaccd
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/11ebaccd
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/11ebaccd

Branch: refs/heads/activemq-5.13.x
Commit: 11ebaccd64db6413abdf3cd60b580e2703df1e8f
Parents: e1cf0d2
Author: Torsten Mielke <tmielke@redhat.com>
Authored: Fri Dec 4 09:39:03 2015 +0100
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Fri Dec 4 15:23:57 2015 -0500

----------------------------------------------------------------------
 .../org/apache/activemq/store/kahadb/disk/journal/Journal.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/11ebaccd/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
----------------------------------------------------------------------
diff --git a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
index 8c82cf2..d00c377 100644
--- a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
+++ b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
@@ -63,7 +63,7 @@ public class Journal {
         try {
             int nextOffset = findNextBatchRecord(reader, recoveryPosition.getOffset() + 1);
             Sequence sequence = new Sequence(recoveryPosition.getOffset(), nextOffset >=
0 ? nextOffset - 1 : dataFile.getLength() - 1);
-            LOG.info("Corrupt journal records found in '" + dataFile.getFile() + "' between
offsets: " + sequence);
+            LOG.warn("Corrupt journal records found in '" + dataFile.getFile() + "' between
offsets: " + sequence);
 
             // skip corruption on getNextLocation
             recoveryPosition.setOffset((int) sequence.getLast() + 1);
@@ -332,7 +332,7 @@ public class Journal {
                     int nextOffset = findNextBatchRecord(reader, location.getOffset()+1);
                     if( nextOffset >=0 ) {
                         Sequence sequence = new Sequence(location.getOffset(), nextOffset
- 1);
-                        LOG.info("Corrupt journal records found in '"+dataFile.getFile()+"'
between offsets: "+sequence);
+                        LOG.warn("Corrupt journal records found in '" + dataFile.getFile()
+ "' between offsets: " + sequence);
                         dataFile.corruptedBlocks.add(sequence);
                         location.setOffset(nextOffset);
                     } else {


Mime
View raw message