def start(self):
        """Start the connection to a transport."""
        self._init_topics()
        poll_thread = threading.Thread(target=self._poll_queue)
        poll_thread.start()
Start the connection to a transport.