Restore generate_messages_from_queue()

This commit is contained in:
R. Richard 2019-08-07 11:24:56 +02:00
parent 09ffe2bdcf
commit 13179e59eb
1 changed files with 8 additions and 0 deletions

View File

@ -28,3 +28,11 @@ class MessageSender:
'key': 'message.config',
'originator': originator
})
@staticmethod
def generate_messages_from_queue(queue_message):
for message in queue_message['value']:
yield {
'key': 'message.send',
**message
}