ocrd_network.rabbitmq_utils.consumer module¶

The source code in this file is adapted by reusing some part of the source code from the official RabbitMQ documentation.

class ocrd_network.rabbitmq_utils.consumer.RMQConsumer(host: str = 'localhost', port: int = 5672, vhost: str = '/')[source]¶

Bases: RMQConnector

authenticate_and_connect(username: str, password: str) → None[source]¶

setup_defaults() → None[source]¶

get_one_message(queue_name: str, auto_ack: bool = False) → Any | None[source]¶

configure_consuming(queue_name: str, callback_method: Any) → None[source]¶

start_consuming() → None[source]¶

get_waiting_message_count() → int | None[source]¶

ack_message(delivery_tag: int) → None[source]¶