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

defer messagebus sync

Browse source
This commit is contained in:
Mike McLean 2016-05-25 17:11:35 -04:00
parent 42b567b327
commit ac5cbf1682
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
plugins/hub/messagebus.py
View file

@ -242,7 +242,7 @@ def send_messages(cbtype, *args, **kws):
return
sender = get_sender()
for message in messages:
sender.send(message, sync=True, timeout=config.getfloat('broker', 'timeout'))
sender.send(message, sync=False, timeout=config.getfloat('broker', 'timeout'))
sender.close(timeout=config.getfloat('broker', 'timeout'))
# koji should do this for us, but just in case...