mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Fix #34

pull/8/head
Nicolas 2016-04-10 23:05:42 +02:00
rodzic e9b806348e
commit 8c3cd9be2a
1 zmienionych plików z 1 dodań i 2 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

3
hbmqtt/mqtt/protocol/broker_handler.py
Wyświetl plik

@ -143,8 +143,7 @@ class BrokerProtocolHandler(ProtocolHandler):
if connect.proto_level != 4: if connect.proto_level != 4:
# only MQTT 3.1.1 supported # only MQTT 3.1.1 supported
error_msg = 'Invalid protocol from %s: %d' % \ error_msg = 'Invalid protocol from %s: %d' % \
(format_client_message(address=remote_address, port=remote_port), (format_client_message(address=remote_address, port=remote_port), connect.proto_level)
connect.variable_header.protocol_level)
connack = ConnackPacket.build(0, UNACCEPTABLE_PROTOCOL_VERSION) # [MQTT-3.2.2-4] session_parent=0 connack = ConnackPacket.build(0, UNACCEPTABLE_PROTOCOL_VERSION) # [MQTT-3.2.2-4] session_parent=0
elif connect.username_flag and connect.username is None: elif connect.username_flag and connect.username is None:
error_msg = 'Invalid username from %s' % \ error_msg = 'Invalid username from %s' % \