diff --git a/core/java/src/net/i2p/util/LogWriter.java b/core/java/src/net/i2p/util/LogWriter.java
index 15c60e566..f695b08a2 100644
--- a/core/java/src/net/i2p/util/LogWriter.java
+++ b/core/java/src/net/i2p/util/LogWriter.java
@@ -47,10 +47,10 @@ class LogWriter extends LogWriterBase {
     }
 
     protected void writeRecord(LogRecord rec, String formatted) {
-    	writeRecord(formatted);
+    	writeRecord(rec.getPriority(), formatted);
     }
 
-    protected synchronized void writeRecord(String val) {
+    protected synchronized void writeRecord(int priority, String val) {
         if (val == null) return;
         if (_currentOut == null) {
             rotateFile();
diff --git a/core/java/src/net/i2p/util/LogWriterBase.java b/core/java/src/net/i2p/util/LogWriterBase.java
index 7448a1862..978439128 100644
--- a/core/java/src/net/i2p/util/LogWriterBase.java
+++ b/core/java/src/net/i2p/util/LogWriterBase.java
@@ -45,9 +45,10 @@ abstract class LogWriterBase implements Runnable {
     protected abstract void writeRecord(LogRecord rec, String formatted);
     /**
      * Write a single String verbatim to the writer.
+     * @param priority the level to log the line at.
      * @param line the String to write.
      */
-    protected abstract void writeRecord(String line);
+    protected abstract void writeRecord(int priority, String line);
     protected abstract void flushWriter();
     protected abstract void closeWriter();
 
@@ -95,7 +96,7 @@ abstract class LogWriterBase implements Runnable {
                         dupCount++;
                     } else {
                         if (dupCount > 0) {
-                            writeRecord(dupMessage(dupCount, _last, false));
+                            writeRecord(_last.getPriority(), dupMessage(dupCount, _last, false));
                             _manager.getBuffer().add(dupMessage(dupCount, _last, true));
                             dupCount = 0;
                         }
@@ -104,7 +105,7 @@ abstract class LogWriterBase implements Runnable {
                     _last = rec;
                 }
                 if (dupCount > 0) {
-                    writeRecord(dupMessage(dupCount, _last, false));
+                    writeRecord(_last.getPriority(), dupMessage(dupCount, _last, false));
                     _manager.getBuffer().add(dupMessage(dupCount, _last, true));
                 }
                 flushWriter();