| 175 | self.service.delete_queue(queue_name) |
| 176 | |
| 177 | def peek_messages(self): |
| 178 | queue_name = self._create_queue() |
| 179 | self.service.put_message(queue_name, u'message1') |
| 180 | self.service.put_message(queue_name, u'message2') |
| 181 | |
| 182 | # Azure queues are not strictly ordered so the below messages returned are estimates |
| 183 | # Ex: We may return message2 for the first sample and then message1 and message2 for the second |
| 184 | |
| 185 | # Basic |
| 186 | # does not change the visibility timeout |
| 187 | # does not return pop_receipt, or time_next_visible |
| 188 | messages = self.service.peek_messages(queue_name) |
| 189 | for message in messages: |
| 190 | print(message.content) # message1 |
| 191 | |
| 192 | # Num messages |
| 193 | messages = self.service.get_messages(queue_name, num_messages=2) |
| 194 | for message in messages: |
| 195 | print(message.content) # message1, message2 |
| 196 | |
| 197 | self.service.delete_queue(queue_name) |
| 198 | |
| 199 | def clear_messages(self): |
| 200 | queue_name = self._create_queue() |