diff --git a/rpc/json/service.go b/rpc/json/service.go
index 8c1f374858..c5ab3eba80 100644
--- a/rpc/json/service.go
+++ b/rpc/json/service.go
@@ -130,9 +130,6 @@ func (s *service) Subscribe(req *http.Request, args *SubscribeArgs, wsConn *wsCo
 					}
 					s.logger.Error("subscription was cancelled", "reason", reason)
 				}
-				if wsConn != nil {
-					close(wsConn.queue)
-				}
 				return
 			}
 		}