code: async def __run_listen(self):
          
          while True:
              message = await ZMQUtils.recv(self.__backend_socket)
              await self.__handle_backend_message(message)
docs: Listen to the backend