(self)
| 197 | self.service.delete_queue(queue_name) |
| 198 | |
| 199 | def clear_messages(self): |
| 200 | queue_name = self._create_queue() |
| 201 | self.service.put_message(queue_name, u'message1') |
| 202 | self.service.put_message(queue_name, u'message2') |
| 203 | |
| 204 | # Basic |
| 205 | self.service.clear_messages(queue_name) |
| 206 | messages = self.service.peek_messages(queue_name) # messages = [] |
| 207 | |
| 208 | self.service.delete_queue(queue_name) |
| 209 | |
| 210 | def delete_message(self): |
| 211 | queue_name = self._create_queue() |