diff --git a/apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketManager.java b/apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketManager.java
index 6bde784623232c2d6a10ab14f7c66362093a1ed6..7c110126513cae3a242df84871a9ce922e5d44d7 100644
--- a/apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketManager.java
+++ b/apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketManager.java
@@ -84,6 +84,7 @@ public class I2PSocketManager implements I2PSessionListener {
 
     public void disconnected(I2PSession session) {
         _log.info("Disconnected from the session");
+        destroySocketManager();
     }
 
     public void errorOccurred(I2PSession session, String message, Throwable error) {