kopia lustrzana https://github.com/Yakifo/amqtt
remove coroutine declaration for check_connect
rodzic
beb3fd4400
commit
a6f19c909b
|
@ -618,7 +618,6 @@ class Broker:
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
self.logger.error(e)
|
self.logger.error(e)
|
||||||
|
|
||||||
@asyncio.coroutine
|
|
||||||
def check_connect(self, connect: ConnectPacket):
|
def check_connect(self, connect: ConnectPacket):
|
||||||
if connect.payload.client_id is None:
|
if connect.payload.client_id is None:
|
||||||
raise BrokerException('[[MQTT-3.1.3-3]] : Client identifier must be present' )
|
raise BrokerException('[[MQTT-3.1.3-3]] : Client identifier must be present' )
|
||||||
|
|
Ładowanie…
Reference in New Issue