@atomic.action_timer("zaqar.list_messages")
    def _messages_list(self, queue):

        return queue.messages()
Gets messages from a given Zaqar queue.
dataset/ETHPy150Open openstack/rally/rally/plugins/openstack/scenarios/zaqar/utils.py/ZaqarScenario._messages_list