diff --git a/src/api_communication/api_communication/api_listener.py b/src/api_communication/api_communication/api_listener.py
index aec9ad76..4b692191 100644
--- a/src/api_communication/api_communication/api_listener.py
+++ b/src/api_communication/api_communication/api_listener.py
@@ -137,7 +137,7 @@ class ApiListener(Node):
         while True:
             if len(self.message_queue) > 0 and self.websocket is not None and self.event_loop is not None:
                 # self.get_logger().info("sending message")
-                asyncio.ensure_future(self.publish_message(self.message_queue.pop(0)), loop=self.event_loop)
+                asyncio.run(self.publish_message(self.message_queue.pop(0)))
 
     def start_api_thread(self):
         asyncio.run(self.handle_api())