Repository: activemq Updated Branches: refs/heads/master be24a133e -> e72545152
This closes #162. Minor improvement in using the Logger api Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/e7254515 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/e7254515 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/e7254515 Branch: refs/heads/master Commit: e725451521a40bd35044bce0fe13a393e10a2b43 Parents: be24a13 Author: Hadrian Zbarcea <hadr...@apache.org> Authored: Thu Nov 3 17:26:00 2016 -0400 Committer: Hadrian Zbarcea <hadr...@apache.org> Committed: Thu Nov 3 17:26:00 2016 -0400 ---------------------------------------------------------------------- .../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/e7254515/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 a417adf..d780b46 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 @@ -93,7 +93,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.warn("Corrupt journal records found in '" + dataFile.getFile() + "' between offsets: " + sequence); + LOG.warn("Corrupt journal records found in '{}' between offsets: {}", dataFile.getFile(), sequence); // skip corruption on getNextLocation recoveryPosition.setOffset((int) sequence.getLast() + 1); @@ -477,7 +477,7 @@ public class Journal { int nextOffset = findNextBatchRecord(reader, location.getOffset() + 1); if (nextOffset >= 0) { Sequence sequence = new Sequence(location.getOffset(), nextOffset - 1); - LOG.warn("Corrupt journal records found in '" + dataFile.getFile() + "' between offsets: " + sequence); + LOG.warn("Corrupt journal records found in '{}' between offsets: {}", dataFile.getFile(), sequence); dataFile.corruptedBlocks.add(sequence); location.setOffset(nextOffset); } else {