diff --git a/java/com/tigervnc/vncviewer/CConn.java b/java/com/tigervnc/vncviewer/CConn.java
index e74cad5..d4ef5e9 100644
--- a/java/com/tigervnc/vncviewer/CConn.java
+++ b/java/com/tigervnc/vncviewer/CConn.java
@@ -383,6 +383,7 @@
       sock = new TcpSocket(host, port);
       vlog.info("Redirected to "+host+":"+port);
       setStreams(sock.inStream(), sock.outStream());
+      sock.inStream().setBlockCallback(this);
       initialiseProtocol();
     } catch (java.lang.Exception e) {
       throw new Exception(e.toString());