|
|
send_register_msg(Socket, TopicName_tom, MsgId1),
|
|
send_register_msg(Socket, TopicName_tom, MsgId1),
|
|
|
TopicId_tom = check_regack_msg_on_udp(MsgId1, receive_response(Socket)),
|
|
TopicId_tom = check_regack_msg_on_udp(MsgId1, receive_response(Socket)),
|
|
|
send_subscribe_msg_predefined_topic(Socket, QoS, TopicId_tom, MsgId1),
|
|
send_subscribe_msg_predefined_topic(Socket, QoS, TopicId_tom, MsgId1),
|
|
|
?assertEqual(<<8, ?SN_SUBACK, Dup:1, QoS:2, Retain:1, WillBit:1, CleanSession:1,
|
|
?assertEqual(<<8, ?SN_SUBACK, Dup:1, QoS:2, Retain:1, WillBit:1, CleanSession:1,
|