|
@@ -59,19 +59,19 @@ if __name__ == '__main__':
|
|
|
# --- init ---
|
|
|
# c1 = Client(host='192.168.131.23', port=41883)
|
|
|
# c1 = Client(host='127.0.0.1', port=41883)
|
|
|
- c1 = Client(host='10.10.10.116', port=41883)
|
|
|
+ # c1 = Client(host='10.10.10.116', port=41883)
|
|
|
+ c1 = Client(host='10.10.60.237', port=41883)
|
|
|
|
|
|
|
|
|
# --- test subscribe ---
|
|
|
def m1(_, __, p3):
|
|
|
- # print(f'#message: {p3.payload}')
|
|
|
- print(f"#message.payload: {json.loads(p3.payload)}")
|
|
|
+ print(f'#message: {p3.payload}')
|
|
|
+ # print(f"#message.payload: {json.loads(p3.payload)}")
|
|
|
|
|
|
-
|
|
|
- # --- test subscribe
|
|
|
# subscribe_topic = 'bg/log'
|
|
|
# subscribe_topic = 'qtmqtt'
|
|
|
- subscribe_topic = 'Vehicle/ControlVehicle/Veh001'
|
|
|
+ # subscribe_topic = 'Vehicle/ControlVehicle/Veh001'
|
|
|
+ subscribe_topic = 'client'
|
|
|
c1.start_subscribe_loop(decorate_method=m1, subscribe_topic=subscribe_topic)
|
|
|
|
|
|
# --- test publish ---
|