Method get_messages

samples/queue/queue_usage.py:149–175

(self)

        self.service.delete_queue(queue_name)

    def get_messages(self):
        queue_name = self._create_queue()
        self.service.put_message(queue_name, u'message1')
        self.service.put_message(queue_name, u'message2')
        self.service.put_message(queue_name, u'message3')
        self.service.put_message(queue_name, u'message4')

        # Azure queues are not strictly ordered so the below messages returned are estimates
        # Ex: We may return message2 for the first sample and then message1 and message3 for the second

        # Basic, only gets 1 message
        messages = self.service.get_messages(queue_name)
        for message in messages:
            print(message.content)  # message1

        # Num messages
        messages = self.service.get_messages(queue_name, num_messages=2)
        for message in messages:
            print(message.content)  # message2, message3

        # Visibility
        messages = self.service.get_messages(queue_name, visibility_timeout=10)
        for message in messages:
            print(message.content)  # message4
        # message4 has a visibility timeout of only 10 seconds rather than 30

        self.service.delete_queue(queue_name)

    def peek_messages(self):
        queue_name = self._create_queue()