kopia lustrzana https://github.com/Yakifo/amqtt
Fix #31
rodzic
8c3cd9be2a
commit
ae7d13af82
|
@ -145,6 +145,10 @@ class BrokerProtocolHandler(ProtocolHandler):
|
|||
error_msg = 'Invalid protocol from %s: %d' % \
|
||||
(format_client_message(address=remote_address, port=remote_port), connect.proto_level)
|
||||
connack = ConnackPacket.build(0, UNACCEPTABLE_PROTOCOL_VERSION) # [MQTT-3.2.2-4] session_parent=0
|
||||
elif not connect.username_flag and connect.password_flag:
|
||||
connack = ConnackPacket.build(0, BAD_USERNAME_PASSWORD) # [MQTT-3.1.2-22]
|
||||
elif connect.username_flag and not connect.password_flag:
|
||||
connack = ConnackPacket.build(0, BAD_USERNAME_PASSWORD) # [MQTT-3.1.2-22]
|
||||
elif connect.username_flag and connect.username is None:
|
||||
error_msg = 'Invalid username from %s' % \
|
||||
(format_client_message(address=remote_address, port=remote_port))
|
||||
|
|
Ładowanie…
Reference in New Issue