dramatiq.messages.total

Total messages processed

Dimensions:None

Available on:

Prometheus

dramatiq_messages_total

Total number of messages processed by Dramatiq

Dimensions:None

Sources

Technical Annotations (10)

Configuration Parameters (2)

--threadsrecommended: Reduce from high values like 40; single thread (--threads=1) works reliably

Controls worker thread count; high values cause consumer thread starvation with CPU-intensive tasks

rabbitmq.heartbeat_timeoutrecommended: Increase from default

Allows longer intervals between heartbeat communication before connection closure

Error Signatures (2)

pika.exceptions.ConnectionWrongStateError: BlockingConnection.add_callback_threadsafe() called on closed or closing connection.

exception

Failed to wait for all callbacks to complete. This can happen when the RabbitMQ server is suddenly restarted.log pattern

CLI Commands (2)

dramatiq example --threads=40 --processes=1diagnostic

dramatiq example --threads=1 --processes=1remediation

Technical References (4)

consumer threadscomponentsys.setswitchintervalcomponentheartbeat intervalconceptdelayed queuecomponent

Task queue failures occur silently without monitoringcritical

▸

Message duplication from RabbitMQ connection closure under CPU-intensive loadcritical

▸