diff --git a/src/main/scala/redis/actors/RedisWorkerIO.scala b/src/main/scala/redis/actors/RedisWorkerIO.scala
index b7668869..94be0208 100644
--- a/src/main/scala/redis/actors/RedisWorkerIO.scala
+++ b/src/main/scala/redis/actors/RedisWorkerIO.scala
@@ -85,8 +85,10 @@ abstract class RedisWorkerIO(val address: InetSocketAddress) extends Actor with
     }
     case a: InetSocketAddress => onAddressChanged(a)
     case c: ConnectionClosed => {
-      if(sender == tcpWorker)
+      if(sender == tcpWorker) {
+        tcpWorker ! ConfirmedClose // close the sending direction of the connection (TCP FIN)
         onConnectionClosed(c)
+      }
       else
         onClosingConnectionClosed()
     }