diff --git a/apps/streaming/java/src/net/i2p/client/streaming/I2PSocketManagerFull.java b/apps/streaming/java/src/net/i2p/client/streaming/I2PSocketManagerFull.java
index a60888f2cc6d74a8d9152b29aad559436d4c4072..01d62b6093a5f29513b0850a5b8f35d06da03fee 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/I2PSocketManagerFull.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/I2PSocketManagerFull.java
@@ -130,7 +130,7 @@ public class I2PSocketManagerFull implements I2PSocketManager {
             _log.debug("receiveSocket() called: " + con);
         }
         if (con != null) {
-            I2PSocketFull sock = new I2PSocketFull(con);
+            I2PSocketFull sock = new I2PSocketFull(con,_context);
             con.setSocket(sock);
             return sock;
         } else { 
@@ -242,7 +242,7 @@ public class I2PSocketManagerFull implements I2PSocketManager {
         Connection con = _connectionManager.connect(peer, opts);
         if (con == null)
             throw new TooManyStreamsException("Too many streams, max " + _defaultOptions.getMaxConns());
-        I2PSocketFull socket = new I2PSocketFull(con);
+        I2PSocketFull socket = new I2PSocketFull(con,_context);
         con.setSocket(socket);
         if (con.getConnectionError() != null) { 
             con.disconnect(false);