|
|
|
@ -8,7 +8,7 @@ def write_config(filename, port):
|
|
|
|
|
with open(filename, 'w') as f:
|
|
|
|
|
f.write("port %d\n" % (port))
|
|
|
|
|
f.write("allow_anonymous true\n")
|
|
|
|
|
f.write("max_packet_size 30\n")
|
|
|
|
|
f.write("max_packet_size 40\n")
|
|
|
|
|
|
|
|
|
|
port = mosq_test.get_port()
|
|
|
|
|
conf_file = os.path.basename(__file__).replace('.py', '.conf')
|
|
|
|
@ -18,7 +18,7 @@ rc = 1
|
|
|
|
|
|
|
|
|
|
keepalive = 10
|
|
|
|
|
connect_packet = mosq_test.gen_connect("12-max-packet-broker", proto_ver=5, keepalive=keepalive)
|
|
|
|
|
props = mqtt5_props.gen_uint32_prop(mqtt5_props.PROP_MAXIMUM_PACKET_SIZE, 30)
|
|
|
|
|
props = mqtt5_props.gen_uint32_prop(mqtt5_props.PROP_MAXIMUM_PACKET_SIZE, 40)
|
|
|
|
|
connack_packet = mosq_test.gen_connack(rc=0, proto_ver=5, properties=props)
|
|
|
|
|
|
|
|
|
|
publish_packet = mosq_test.gen_publish("12/max/packet/size/broker/test/topic", qos=0, payload="0123456789012345678901234567890", proto_ver=5)
|
|
|
|
|