pynenc_rabbitmq.util.rabbitmq_queue_mng

Queue manager for RabbitMQ operations with automatic retry.

Module Contents

Classes

QueueManager

Manages queue operations with automatic retry on connection failures.

Data

logger

API

pynenc_rabbitmq.util.rabbitmq_queue_mng.logger

‘getLogger(…)’

class pynenc_rabbitmq.util.rabbitmq_queue_mng.QueueManager(connection_manager: pynenc_rabbitmq.util.rabbitmq_conn_mng.ConnectionManager, spec: pynenc_rabbitmq.util.rabbitmq_queue.QueueSpec)

Manages queue operations with automatic retry on connection failures.

Wraps all queue operations with exponential backoff retry logic to handle transient connection issues gracefully.

Initialization

_get_retry_config() → dict[str, Any]

Get retry configuration from connection manager config.

_retry_operation(operation: collections.abc.Callable[[], Any], operation_name: str) → Any

Execute operation with configured retry logic.

publish_message(message: str) → bool

Publish a message to the queue with retry logic.

Parameters:

message – Message content to publish

Returns:

True if successful, False on error

consume_message() → str | None

Consume a single message from the queue with retry logic.

Returns:

Message content or None if queue is empty

get_message_count() → int

Get the number of messages in the queue with retry logic.

Returns:

Number of messages in queue

purge_queue() → int

Clear all messages from the queue with retry logic.

Returns:

Number of messages purged