You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ha...@apache.org on 2016/11/03 21:26:09 UTC
activemq git commit: This closes #162. Minor improvement in using the
Logger api
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 <ha...@apache.org>
Authored: Thu Nov 3 17:26:00 2016 -0400
Committer: Hadrian Zbarcea <ha...@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 {