From 84b228cf2275358c5735261ba96656b9e12e32fd 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:20 +0100
Subject: [PATCH] add keep alive

---
 code/infrastructure/streaming/clients/sub/memgraph/sub_mem.py | 2 +-
 code/infrastructure/streaming/clients/sub/ongdb/sub_ongdb.py  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/code/infrastructure/streaming/clients/sub/memgraph/sub_mem.py b/code/infrastructure/streaming/clients/sub/memgraph/sub_mem.py
index 2bf6bac..592eae6 100644
--- a/code/infrastructure/streaming/clients/sub/memgraph/sub_mem.py
+++ b/code/infrastructure/streaming/clients/sub/memgraph/sub_mem.py
@@ -261,7 +261,7 @@ client.on_connect = on_connect
 client.on_message = on_message
 client.failed_connect = False
 
-client.connect(broker_hostname, broker_port) 
+client.connect(broker_hostname, broker_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   
diff --git a/code/infrastructure/streaming/clients/sub/ongdb/sub_ongdb.py b/code/infrastructure/streaming/clients/sub/ongdb/sub_ongdb.py
index 6fb3f7e..5e11758 100644
--- a/code/infrastructure/streaming/clients/sub/ongdb/sub_ongdb.py
+++ b/code/infrastructure/streaming/clients/sub/ongdb/sub_ongdb.py
@@ -261,7 +261,7 @@ client.on_connect = on_connect
 client.on_message = on_message
 client.failed_connect = False
 
-client.connect(broker_hostname, broker_port) 
+client.connect(broker_hostname, broker_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