diff --git a/fstream-server.py b/fstream-server.py
index 6a958ca..f8e7f7e 100644
--- a/fstream-server.py
+++ b/fstream-server.py
@@ -205,7 +205,7 @@ class inThread(threading.Thread):
 								if accumulatedData > maxAccumulatedData and not thread.ignore:
 									thread.ignore = True
 									thread.queue.put((thread.closeThread,[],{}))
-									thread.connection.close()
+									thread.closeConnection()
 								else:
 									thread.queue.put(data)