diff --git a/apps/streaming/java/src/net/i2p/client/streaming/impl/PacketQueue.java b/apps/streaming/java/src/net/i2p/client/streaming/impl/PacketQueue.java
index 96222a8a2..1eb10c7fb 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/impl/PacketQueue.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/impl/PacketQueue.java
@@ -85,17 +85,10 @@ class PacketQueue implements SendMessageStatusListener {
         //if (tagsSent == null)
         //    tagsSent = new HashSet(0);
 
-        // cache this from before sendMessage
-        String conStr = null;
-        if (_log.shouldLog(Log.DEBUG))
-            conStr = (packet.getConnection() != null ? packet.getConnection().toString() : "");
         if (packet.getAckTime() > 0) {
             if (_log.shouldLog(Log.DEBUG))
                 _log.debug("Not resending " + packet);
             return false;
-        } else {
-            if (_log.shouldLog(Log.DEBUG))
-                _log.debug("Sending... " + packet);
         }
     
         ByteArray ba = _cache.acquire();
@@ -205,13 +198,6 @@ class PacketQueue implements SendMessageStatusListener {
             //packet.setKeyUsed(keyUsed);
             //packet.setTagsSent(tagsSent);
             packet.incrementSends();
-            if (_log.shouldLog(Log.DEBUG)) {
-                String msg = "SEND " + packet
-                             + " send # " + packet.getNumSends()
-                             + " sendTime: " + (end-begin)
-                             + " con: " + conStr;
-                _log.debug(msg);
-            }
             Connection c = packet.getConnection();
             String suffix = (c != null ? "wsize " + c.getOptions().getWindowSize() + " rto " + c.getOptions().getRTO() : null);
             if (_log.shouldDebug())