diff --git a/health_check/contrib/rabbitmq/backends.py b/health_check/contrib/rabbitmq/backends.py index d09a79d9..63a9a82c 100644 --- a/health_check/contrib/rabbitmq/backends.py +++ b/health_check/contrib/rabbitmq/backends.py @@ -13,11 +13,14 @@ class RabbitMQHealthCheck(BaseHealthCheckBackend): """Health check for RabbitMQ.""" + namespace = None + def check_status(self): """Check RabbitMQ service by opening and closing a broker channel.""" logger.debug("Checking for a broker_url on django settings...") - broker_url = getattr(settings, "BROKER_URL", None) + broker_url_setting_key = f"{self.namespace}_BROKER_URL" if self.namespace else "BROKER_URL" + broker_url = getattr(settings, broker_url_setting_key, None) logger.debug("Got %s as the broker_url. Connecting to rabbit...", broker_url)