diff --git a/apps/streaming/java/src/net/i2p/client/streaming/Connection.java b/apps/streaming/java/src/net/i2p/client/streaming/Connection.java
index ee3b1627a..2ab965993 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/Connection.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/Connection.java
@@ -584,7 +584,7 @@ public class Connection {
                 
                 // shrink the window
                 int newWindowSize = getOptions().getWindowSize();
-                _lastCongestionSeenAt = newWindowSize;
+                congestionOccurred();
                 newWindowSize /= 2;
                 if (newWindowSize <= 0)
                     newWindowSize = 1;