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'