(self)
| 265 | |
| 266 | @record |
| 267 | def test_get_messages(self): |
| 268 | # Action |
| 269 | queue_name = self._create_queue() |
| 270 | self.qs.put_message(queue_name, u'message1') |
| 271 | self.qs.put_message(queue_name, u'message2') |
| 272 | self.qs.put_message(queue_name, u'message3') |
| 273 | self.qs.put_message(queue_name, u'message4') |
| 274 | result = self.qs.get_messages(queue_name) |
| 275 | |
| 276 | # Asserts |
| 277 | self.assertIsNotNone(result) |
| 278 | self.assertEqual(1, len(result)) |
| 279 | message = result[0] |
| 280 | self.assertIsNotNone(message) |
| 281 | self.assertNotEqual('', message.id) |
| 282 | self.assertEqual(u'message1', message.content) |
| 283 | self.assertNotEqual('', message.pop_receipt) |
| 284 | self.assertEqual(1, message.dequeue_count) |
| 285 | |
| 286 | self.assertIsInstance(message.insertion_time, datetime) |
| 287 | self.assertIsInstance(message.expiration_time, datetime) |
| 288 | self.assertIsInstance(message.time_next_visible, datetime) |
| 289 | |
| 290 | @record |
| 291 | def test_get_messages_with_options(self): |
nothing calls this directly
no test coverage detected