|
|
|
@ -4,7 +4,7 @@
|
|
|
|
|
|
|
|
|
|
from mosq_test_helper import *
|
|
|
|
|
|
|
|
|
|
def do_test(format_str, expected_output, proto_ver=4):
|
|
|
|
|
def do_test(format_str, expected_output, proto_ver=4, payload="message"):
|
|
|
|
|
rc = 1
|
|
|
|
|
|
|
|
|
|
port = mosq_test.get_port()
|
|
|
|
@ -32,7 +32,6 @@ def do_test(format_str, expected_output, proto_ver=4):
|
|
|
|
|
if proto_ver == 5:
|
|
|
|
|
cmd += ['-D', 'subscribe', 'subscription-identifier', '56']
|
|
|
|
|
|
|
|
|
|
payload = "message"
|
|
|
|
|
props = mqtt5_props.gen_byte_prop(mqtt5_props.PROP_PAYLOAD_FORMAT_INDICATOR, 1)
|
|
|
|
|
props += mqtt5_props.gen_uint32_prop(mqtt5_props.PROP_MESSAGE_EXPIRY_INTERVAL, 3600)
|
|
|
|
|
props += mqtt5_props.gen_string_prop(mqtt5_props.PROP_CONTENT_TYPE, "plain/text")
|
|
|
|
@ -126,3 +125,5 @@ do_test('\\t', '\t\n')
|
|
|
|
|
do_test('\\v', '\v\n')
|
|
|
|
|
do_test('@@', '@\n')
|
|
|
|
|
do_test('text', 'text\n')
|
|
|
|
|
do_test('%.3d', '2.718\n', payload=struct.pack('BBBBBBBB', 0x58, 0x39, 0xB4, 0xC8, 0x76, 0xBE, 0x05, 0x40))
|
|
|
|
|
do_test('%.3f', '0.707\n', payload=struct.pack('BBBB', 0xF4, 0xFD, 0x34, 0x3F))
|
|
|
|
|