diff --git a/router/java/src/net/i2p/router/client/ClientConnectionRunner.java b/router/java/src/net/i2p/router/client/ClientConnectionRunner.java
index fc046f3e6cce033b44c07b7b92ed20d87fc4998d..446ccd3c0756eb3f1f1c7b07ca35dce0c6fbf507 100644
--- a/router/java/src/net/i2p/router/client/ClientConnectionRunner.java
+++ b/router/java/src/net/i2p/router/client/ClientConnectionRunner.java
@@ -56,7 +56,7 @@ import net.i2p.util.SimpleTimer;
  * @author jrandom
  */
 class ClientConnectionRunner {
-    private final Log _log;
+    protected final Log _log;
     protected final RouterContext _context;
     private final ClientManager _manager;
     /** socket for this particular peer connection */
diff --git a/router/java/src/net/i2p/router/client/QueuedClientConnectionRunner.java b/router/java/src/net/i2p/router/client/QueuedClientConnectionRunner.java
index 7f23f051bc4dfb81d9a496f7136e5fabf12ba639..aa2e9415c30c190019d4eb83b1106d4533f61f55 100644
--- a/router/java/src/net/i2p/router/client/QueuedClientConnectionRunner.java
+++ b/router/java/src/net/i2p/router/client/QueuedClientConnectionRunner.java
@@ -5,6 +5,7 @@ import net.i2p.data.i2cp.I2CPMessageException;
 import net.i2p.internal.I2CPMessageQueue;
 import net.i2p.internal.QueuedI2CPMessageReader;
 import net.i2p.router.RouterContext;
+import net.i2p.util.Log;
 
 /**
  * Zero-copy in-JVM.
@@ -67,8 +68,8 @@ class QueuedClientConnectionRunner extends ClientConnectionRunner {
         // with non-blocking writes for the router
         // and blocking writes for the client?
         boolean success = queue.offer(msg);
-        if (!success)
-            throw new I2CPMessageException("I2CP write to queue failed");
+        if (!success && _log.shouldLog(Log.WARN))
+            _log.warn("I2CP write to queue failed: " + msg);
     }
     
 }