diff --git a/pycti/connector/opencti_connector_helper.py b/pycti/connector/opencti_connector_helper.py
index e106af77..de162061 100644
--- a/pycti/connector/opencti_connector_helper.py
+++ b/pycti/connector/opencti_connector_helper.py
@@ -1424,6 +1424,7 @@ def listen(
             message_callback,
         )
         self.listen_queue.start()
+        self.listen_queue.join()
 
     def listen_stream(
         self,