From abf37e98e10f1c736ae90ee4cf987193f245ac53 Mon Sep 17 00:00:00 2001 From: Filip Valder Date: Thu, 12 Jan 2017 19:57:34 +0100 Subject: [PATCH] in_memory messaging -> fallback to '*' topics --- module_build_service/messaging.py | 1 + module_build_service/scheduler/consumer.py | 2 ++ 2 files changed, 3 insertions(+) diff --git a/module_build_service/messaging.py b/module_build_service/messaging.py index 571c6220..85fc13ab 100644 --- a/module_build_service/messaging.py +++ b/module_build_service/messaging.py @@ -364,5 +364,6 @@ _messaging_backends = { }, 'in_memory': { 'publish': _in_memory_publish, + 'services': [] } } diff --git a/module_build_service/scheduler/consumer.py b/module_build_service/scheduler/consumer.py index 6c0bfc3d..9d206d22 100644 --- a/module_build_service/scheduler/consumer.py +++ b/module_build_service/scheduler/consumer.py @@ -48,6 +48,8 @@ class MBSConsumer(fedmsg.consumers.FedmsgConsumer): in itertools.product( conf.messaging_topic_prefix, module_build_service.messaging._messaging_backends[conf.messaging]['services'])] + if not topic: + topic = '*' log.debug('Setting topics: {}'.format(', '.join(topic))) config_key = 'mbsconsumer'