diff --git a/apps/streaming/java/src/net/i2p/client/streaming/ConnThrottler.java b/apps/streaming/java/src/net/i2p/client/streaming/ConnThrottler.java
index 5383873e9cb3718a45a115f47b70facfd413a283..edf7963fc38f2e5050047135290d9beca3d7de4f 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/ConnThrottler.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/ConnThrottler.java
@@ -27,7 +27,6 @@ class ConnThrottler {
     ConnThrottler(int max, int totalMax, long period) {
         _max = max;
         _totalMax = totalMax;
-        SimpleScheduler.getInstance().addPeriodicEvent(new Cleaner(), period);
         if (max > 0)
             this.counter = new ObjectCounter();
         else
@@ -36,6 +35,7 @@ class ConnThrottler {
             _currentTotal = new AtomicInteger();
         else
             _currentTotal = null;
+        SimpleScheduler.getInstance().addPeriodicEvent(new Cleaner(), period);
     }
 
     /** increments before checking */