diff --git a/src/cosalib/fedora_messaging_request.py b/src/cosalib/fedora_messaging_request.py
index 608bcd9cb0..afb2c67808 100644
--- a/src/cosalib/fedora_messaging_request.py
+++ b/src/cosalib/fedora_messaging_request.py
@@ -194,8 +194,7 @@ def error_cb(failure):
         }
     }
 
-    for d in twisted_consume(callback, bindings=bindings, queues=queues):
-        d.addCallback(registered_cb)
-        d.addErrback(error_cb)  # pylint: disable=E1101
-
+    consumers = twisted_consume(callback, bindings=bindings, queues=queues)
+    consumers.addCallback(registered_cb)  # pylint: disable=E1101
+    consumers.addErrback(error_cb)  # pylint: disable=E1101
     reactor.run(installSignalHandlers=False)  # pylint: disable=E1101