From 258c1f1356d98fc7c96d36b300612e65cca461bb Mon Sep 17 00:00:00 2001
From: Aurélien Bompard <aurelien@bompard.org>
Date: Nov 23 2017 14:50:27 +0000
Subject: Read the default Fedmsg config in the consumer


---

diff --git a/hubs/backend/consumer.py b/hubs/backend/consumer.py
index fa84545..080f919 100644
--- a/hubs/backend/consumer.py
+++ b/hubs/backend/consumer.py
@@ -2,13 +2,15 @@
 
 from __future__ import unicode_literals
 
+import logging
+
 import fedmsg.consumers
 import fedmsg.meta
-
 import retask.task
 import retask.queue
 
-import logging
+from hubs.utils import get_fedmsg_config
+
 log = logging.getLogger("hubs")
 
 
@@ -17,11 +19,16 @@ class CacheInvalidatorExtraordinaire(fedmsg.consumers.FedmsgConsumer):
     config_key = 'hubs.consumer.enabled'
     validate_signatures = False
 
-    def __init__(self, *args, **kwargs):
+    def __init__(self, hub):
+        # Monkey-patch the hub config. I'm not very proud of that one but I
+        # didn't find any other way to tell Fedmsg to read my default config.
+        fedmsg_config = get_fedmsg_config()
+        hub.config = fedmsg_config
+
         log.debug("CacheInvalidatorExtraordinaire initializing")
-        super(CacheInvalidatorExtraordinaire, self).__init__(*args, **kwargs)
+        super(CacheInvalidatorExtraordinaire, self).__init__(hub)
 
-        queue_name = self.hub.config['hubs.redis.triage-queue-name']
+        queue_name = hub.config['hubs.redis.triage-queue-name']
         self.queue = retask.queue.Queue(queue_name)
 
         log.debug("CacheInvalidatorExtraordinaire initialized")