diff --git a/tfw/components/frontend/message_sender.py b/tfw/components/frontend/message_sender.py index 0f4f249..93826df 100644 --- a/tfw/components/frontend/message_sender.py +++ b/tfw/components/frontend/message_sender.py @@ -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 + }