From 9b512ef82c0fdb59173b6a649a17f05ef5cb6699 Mon Sep 17 00:00:00 2001 From: cwy-p8d-u1 <sven-ove.haensel@stud.hs-hannover.de> Date: Fri, 15 Mar 2024 14:57:39 +0100 Subject: [PATCH] add keepalive and quality of service --- .../streaming/clients/sub/neo4j/sub_neo4j_cdm.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/code/infrastructure/streaming/clients/sub/neo4j/sub_neo4j_cdm.py b/code/infrastructure/streaming/clients/sub/neo4j/sub_neo4j_cdm.py index eeceb86..224d8e9 100755 --- a/code/infrastructure/streaming/clients/sub/neo4j/sub_neo4j_cdm.py +++ b/code/infrastructure/streaming/clients/sub/neo4j/sub_neo4j_cdm.py @@ -214,7 +214,7 @@ def on_connect(client, userdata, flags, return_code): ''' if return_code == 0: print("connected") - client.subscribe("neo4j") + client.subscribe("neo4j",qos=1) else: print("could not connect, return code:", return_code) client.failed_connect = True @@ -263,7 +263,7 @@ client.on_connect = on_connect client.on_message = on_message client.failed_connect = False -client.connect(broker_hostname, port) +client.connect(broker_hostname, port,keepalive=3600*4) client.loop_start() # this try-finally block ensures that whenever we terminate the program earlier by hitting ctrl+c, it still gracefully exits -- GitLab