diff --git a/voice_recognition.py b/voice_recognition.py
index 51a3156..d617bee 100644
--- a/voice_recognition.py
+++ b/voice_recognition.py
@@ -89,7 +89,7 @@ class SRBuffer(voice_recv.AudioSink):
         self.wavewriter = {}
 
     def on_user_connect(self, username):
-        self.wavewriter[str(username.id)] = [WaveWriter(username), time.time_ns(), False, True]
+        self.wavewriter[str(username.id)] = [WaveWriter(username), time.time_ns(), False, True, self.queue]
 
     def on_user_disconnect(self,username):
         self.wavewriter[str(username.id)].cleanup()