modules/fm-orchestrator
1
0
Fork 0
mirror of https://pagure.io/fm-orchestrator.git synced 2026-04-04 03:08:21 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

MBSConsumer: Handle initial messages in right order, override validate for non-fedmsg messaging backends.

Browse Source
This commit is contained in:
Jan Kaluza
2016-12-19 09:10:36 +01:00
parent cc5b363b28
commit 174e657379
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
module_build_service/scheduler/consumer.py
View File

@@ -58,7 +58,7 @@ class MBSConsumer(fedmsg.consumers.FedmsgConsumer):
# Furthermore, extend our initial messages with any that were queued up
# in the test environment before our hub was initialized.
while module_build_service.messaging._initial_messages:
msg = module_build_service.messaging._initial_messages.pop()
msg = module_build_service.messaging._initial_messages.pop(0)
self.incoming.put(msg)
# These are our main lookup tables for figuring out what to run in
@@ -96,6 +96,10 @@ class MBSConsumer(fedmsg.consumers.FedmsgConsumer):
reactor.callFromThread(self.hub.stop)
reactor.callFromThread(reactor.stop)
def validate(self, message):
if conf.messaging == 'fedmsg':
super(MBSConsumer, self).validate(message)
def consume(self, message):
log.info("Received %r" % message)