diff --git a/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionManager.java b/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionManager.java
index 3e09c79978901455221b4678c01f0d73a9693afc..5924e818c5fbbcf9d06632cbbab7c6d0dc4245ae 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionManager.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionManager.java
@@ -612,6 +612,16 @@ class ConnectionManager {
             return new HashSet<Connection>(_connectionByInboundId.values());
     }
 
+    /**
+     *  blocking
+     *
+     *  @param timeoutMs greater than zero
+     *  @return true if pong received
+     */
+    public boolean ping(Destination peer, long timeoutMs) {
+        return ping(peer, 0, 0, timeoutMs, true, null);
+    }
+
     /**
      *  blocking
      *