This commit is contained in:
Kristóf Tóth 2018-07-20 10:27:58 +02:00
parent bd6cdc5409
commit 3e5dd6e102

View File

@ -46,8 +46,8 @@ class MessageSender:
})
@staticmethod
def generate_messages_from_queue(queue_messsge):
for message in queue_messsge['data']['messages']:
def generate_messages_from_queue(queue_message):
for message in queue_message['data']['messages']:
yield {
'key': 'message',
'data': message