(self)
| 360 | |
| 361 | @record |
| 362 | def test_clear_messages(self): |
| 363 | # Action |
| 364 | queue_name = self._create_queue() |
| 365 | self.qs.put_message(queue_name, u'message1') |
| 366 | self.qs.put_message(queue_name, u'message2') |
| 367 | self.qs.put_message(queue_name, u'message3') |
| 368 | self.qs.put_message(queue_name, u'message4') |
| 369 | self.qs.clear_messages(queue_name) |
| 370 | result = self.qs.peek_messages(queue_name) |
| 371 | |
| 372 | # Asserts |
| 373 | self.assertIsNotNone(result) |
| 374 | self.assertEqual(0, len(result)) |
| 375 | |
| 376 | @record |
| 377 | def test_delete_message(self): |
nothing calls this directly
no test coverage detected