diff --git a/hbmqtt/broker.py b/hbmqtt/broker.py index ca0e3e2..89073f1 100644 --- a/hbmqtt/broker.py +++ b/hbmqtt/broker.py @@ -93,8 +93,8 @@ class Broker: new_session.writer = writer handler = BrokerProtocolHandler(new_session, self._loop) self._handlers.append(handler) - yield from handler.start() self.logger.debug("Start messages handling") - yield from handler.wait_disconnect() + yield from handler.start() self.logger.debug("Wait for disconnect") + yield from handler.wait_disconnect() yield from handler.stop() \ No newline at end of file