diff --git a/samples/basic_discovery.py b/samples/basic_discovery.py index 4c99aa8a..001e7cbb 100644 --- a/samples/basic_discovery.py +++ b/samples/basic_discovery.py @@ -81,7 +81,7 @@ def try_iot_endpoints(): on_connection_resumed=on_connection_resumed, client_id=args.thing_name, clean_session=False, - keep_alive_secs=6) + keep_alive_secs=30) connect_future = mqtt_connection.connect() connect_future.result() diff --git a/samples/fleetprovisioning.py b/samples/fleetprovisioning.py index fe3d25fe..1384f4bd 100644 --- a/samples/fleetprovisioning.py +++ b/samples/fleetprovisioning.py @@ -249,7 +249,7 @@ def waitForRegisterThingResponse(): ca_filepath=args.root_ca, client_id=args.client_id, clean_session=False, - keep_alive_secs=6) + keep_alive_secs=30) else: mqtt_connection = mqtt_connection_builder.mtls_from_path( @@ -262,7 +262,7 @@ def waitForRegisterThingResponse(): on_connection_interrupted=on_connection_interrupted, on_connection_resumed=on_connection_resumed, clean_session=False, - keep_alive_secs=6, + keep_alive_secs=30, http_proxy_options=proxy_options) print("Connecting to {} with client ID '{}'...".format( diff --git a/samples/jobs.py b/samples/jobs.py index 6b165b8b..8639cd1e 100644 --- a/samples/jobs.py +++ b/samples/jobs.py @@ -244,7 +244,7 @@ def on_update_job_execution_rejected(rejected): ca_filepath=args.root_ca, client_id=args.client_id, clean_session=False, - keep_alive_secs=6) + keep_alive_secs=30) else: mqtt_connection = mqtt_connection_builder.mtls_from_path( @@ -255,7 +255,7 @@ def on_update_job_execution_rejected(rejected): ca_filepath=args.root_ca, client_id=args.client_id, clean_session=False, - keep_alive_secs=6, + keep_alive_secs=30, http_proxy_options=proxy_options) print("Connecting to {} with client ID '{}'...".format( diff --git a/samples/pubsub.py b/samples/pubsub.py index 1d1a4d27..4c712435 100644 --- a/samples/pubsub.py +++ b/samples/pubsub.py @@ -107,7 +107,7 @@ def on_message_received(topic, payload, dup, qos, retain, **kwargs): on_connection_resumed=on_connection_resumed, client_id=args.client_id, clean_session=False, - keep_alive_secs=6) + keep_alive_secs=30) else: mqtt_connection = mqtt_connection_builder.mtls_from_path( @@ -121,7 +121,7 @@ def on_message_received(topic, payload, dup, qos, retain, **kwargs): on_connection_resumed=on_connection_resumed, client_id=args.client_id, clean_session=False, - keep_alive_secs=6, + keep_alive_secs=30, http_proxy_options=proxy_options) print("Connecting to {} with client ID '{}'...".format( diff --git a/samples/shadow.py b/samples/shadow.py index 1bc011b0..61d06825 100644 --- a/samples/shadow.py +++ b/samples/shadow.py @@ -298,7 +298,7 @@ def user_input_thread_fn(): ca_filepath=args.root_ca, client_id=args.client_id, clean_session=True, - keep_alive_secs=6) + keep_alive_secs=30) else: mqtt_connection = mqtt_connection_builder.mtls_from_path( @@ -309,7 +309,7 @@ def user_input_thread_fn(): ca_filepath=args.root_ca, client_id=args.client_id, clean_session=True, - keep_alive_secs=6, + keep_alive_secs=30, http_proxy_options=proxy_options) print("Connecting to {} with client ID '{}'...".format(