ocrd_network.rabbitmq_utils.helpers module

ocrd_network.rabbitmq_utils.helpers.connect_rabbitmq_consumer(logger: Logger, rmq_data: Dict) → RMQConsumer

ocrd_network.rabbitmq_utils.helpers.connect_rabbitmq_publisher(logger: Logger, rmq_data: Dict, enable_acks: bool = True) → RMQPublisher

ocrd_network.rabbitmq_utils.helpers.check_if_queue_exists(logger: Logger, rmq_data: Dict, processor_name: str) → bool

ocrd_network.rabbitmq_utils.helpers.create_message_queues(logger: Logger, rmq_publisher: RMQPublisher, queue_names: List[str]) → None

ocrd_network.rabbitmq_utils.helpers.verify_and_parse_mq_uri(rabbitmq_address: str)

Check the full list of available parameters in the docs here: https://pika.readthedocs.io/en/stable/_modules/pika/connection.html#URLParameters

ocrd_network.rabbitmq_utils.helpers.verify_rabbitmq_available(logger: Logger, rabbitmq_address: str) → None