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 2fd58533d80f628462e63b1d550475e2365f0204..3d2b6fb2d14820e9109568575ef9f9238ae7a6c6 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/ConnThrottler.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/ConnThrottler.java
@@ -4,6 +4,7 @@ import java.util.concurrent.atomic.AtomicInteger;
 
 import net.i2p.data.Hash;
 import net.i2p.util.ObjectCounter;
+import net.i2p.util.RandomSource;
 import net.i2p.util.SimpleScheduler;
 import net.i2p.util.SimpleTimer;
 
@@ -29,7 +30,12 @@ class ConnThrottler {
         _totalMax = totalMax;
         this.counter = new ObjectCounter<Hash>();
         _currentTotal = new AtomicInteger();
-        SimpleScheduler.getInstance().addPeriodicEvent(new Cleaner(), period);
+        // shorten the initial period by a random amount,mpleScheduler.getInstance().addPeriodicEvent(new Cleaner(),
+        // to prevent correlation across destinations
+        // and identification of router startup time
+        SimpleScheduler.getInstance().addPeriodicEvent(new Cleaner(),
+                                                       RandomSource.getInstance().nextLong(period),
+                                                       period);
     }
 
     /*