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

clear message cache after sending

Browse source
This commit is contained in:
Mike McLean 2016-05-25 16:46:32 -04:00
parent ec53e01547
commit 42b567b327
1 changed files with 6 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

7
plugins/hub/messagebus.py
View file

@ -234,11 +234,16 @@ def prep_message(cbtype, *args, **kws):
@callback('postCommit')
@ignore_error
def send_messages(cbtype, *args, **kws):
'''Send the cached message from the other callback'''
'''Send the messages cached by prep_message'''
global config
messages = getattr(context, 'messagebus_plugin_messages', [])
if not messages:
return
sender = get_sender()
for message in messages:
sender.send(message, sync=True, timeout=config.getfloat('broker', 'timeout'))
sender.close(timeout=config.getfloat('broker', 'timeout'))
# koji should do this for us, but just in case...
del context.messagebus_plugin_messages