particle-os/debian-koji
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

protonmsg plugin: test mode

Browse source
This commit is contained in:
Mike McLean 2017-08-03 16:19:03 -04:00
parent 60774a4eb8
commit bce4e28ed8
1 changed files with 8 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

8
plugins/hub/protonmsg.py
View file

@ -261,6 +261,14 @@ def send_queued_msgs(cbtype, *args, **kws):
conf.readfp(conffile)
CONFIG = conf
urls = CONFIG.get('broker', 'urls').split()
test_mode = False
if CONFIG.has_option('broker', 'test_mode'):
test_mode = CONFIG.getboolean('broker', 'test_mode')
if test_mode:
log.debug('test mode: skipping send to urls: %r', urls)
for msg in msgs:
log.debug('test mode: skipped msg: %r', msg)
return
for url in sorted(urls, key=lambda k: random.random()):
container = Container(TimeoutHandler(url, msgs, CONFIG))
container.run()