Rabbitmq heartbeat env

src/ocrd/cli/__init__.py

@@ -47,6 +47,8 @@
 \b
 {config.describe('OCRD_NETWORK_RABBITMQ_CLIENT_CONNECT_ATTEMPTS')}
 \b
+{config.describe('OCRD_NETWORK_RABBITMQ_HEARTBEAT')}
+\b
 {config.describe('OCRD_PROFILE_FILE')}
 \b
 {config.describe('OCRD_PROFILE', wrap_text=False)}

src/ocrd_network/rabbitmq_utils/connector.py

@@ -6,6 +6,7 @@
 from typing import Any, Optional, Union
 from pika import BasicProperties, BlockingConnection, ConnectionParameters, PlainCredentials
 from pika.adapters.blocking_connection import BlockingChannel
+from ocrd_utils import config
 from .constants import (
  DEFAULT_EXCHANGER_NAME,
  DEFAULT_EXCHANGER_TYPE,
@@ -69,8 +70,7 @@ def open_blocking_connection(
  port=port,
  virtual_host=vhost,
  credentials=credentials,
- # TODO: The heartbeat should not be disabled (0)!
- heartbeat=0
+ heartbeat=config.OCRD_NETWORK_RABBITMQ_HEARTBEAT
  ),
  )
  return blocking_connection

src/ocrd_utils/config.py

@@ -176,9 +176,19 @@ def _ocrd_download_timeout_parser(val):
  default=(True, ''))
 
 config.add("OCRD_NETWORK_RABBITMQ_CLIENT_CONNECT_ATTEMPTS",
- description="Number of attempts for a RabbitMQ client to connect before failing.",
+ description="Number of attempts for a RabbitMQ client to connect before failing.",
+ parser=int,
+ default=(True, 3))
+
+config.add(
+ name="OCRD_NETWORK_RABBITMQ_HEARTBEAT",
+ description="""
+ Controls AMQP heartbeat timeout (in seconds) negotiation during connection tuning. An integer value always overrides the value 
+ proposed by broker. Use 0 to deactivate heartbeat.
+ """,
  parser=int,
- default=(True, 3))
+ default=(True, 0)
+)
 
 config.add(name="OCRD_NETWORK_SOCKETS_ROOT_DIR",
  description="The root directory where all mets server related socket files are created",

tests/network/config.py

@@ -89,11 +89,19 @@
 
 test_config.add(
  name="OCRD_NETWORK_RABBITMQ_CLIENT_CONNECT_ATTEMPTS",
+ description="Number of attempts for a RabbitMQ client to connect before failing",
+ parser=int,
+ default=(True, 3)
+)
+
+test_config.add(
+ name="OCRD_NETWORK_RABBITMQ_HEARTBEAT",
  description="""
- Number of attempts for a RabbitMQ client to connect before failing
+ Controls AMQP heartbeat timeout (in seconds) negotiation during connection tuning. An integer value always overrides the value 
+ proposed by broker. Use 0 to deactivate heartbeat.
  """,
  parser=int,
- default=(True, 3)
+ default=(True, 0)
 )
 
 test_config.add(