| 22 | |
| 23 | |
| 24 | class QueueSamples(): |
| 25 | def __init__(self, account): |
| 26 | self.account = account |
| 27 | |
| 28 | def run_all_samples(self): |
| 29 | self.service = self.account.create_queue_service() |
| 30 | |
| 31 | self.create_queue() |
| 32 | self.delete_queue() |
| 33 | self.exists() |
| 34 | self.metadata() |
| 35 | |
| 36 | self.put_message() |
| 37 | self.get_messages() |
| 38 | self.peek_messages() |
| 39 | self.clear_messages() |
| 40 | self.delete_message() |
| 41 | self.update_message() |
| 42 | |
| 43 | self.list_queues() |
| 44 | self.alternative_encoding() |
| 45 | |
| 46 | # This method contains sleeps, so don't run by default |
| 47 | # self.service_properties() |
| 48 | |
| 49 | def _get_queue_reference(self, prefix='queue'): |
| 50 | queue_name = '{}{}'.format(prefix, str(uuid.uuid4()).replace('-', '')) |
| 51 | return queue_name |
| 52 | |
| 53 | def _create_queue(self, prefix='queue'): |
| 54 | queue_name = self._get_queue_reference(prefix) |
| 55 | self.service.create_queue(queue_name) |
| 56 | return queue_name |
| 57 | |
| 58 | def create_queue(self): |
| 59 | # Basic |
| 60 | queue_name1 = self._get_queue_reference() |
| 61 | created = self.service.create_queue(queue_name1) # True |
| 62 | |
| 63 | # Metadata |
| 64 | metadata = {'val1': 'foo', 'val2': 'blah'} |
| 65 | queue_name2 = self._get_queue_reference() |
| 66 | created = self.service.create_queue(queue_name2, metadata=metadata) # True |
| 67 | |
| 68 | # Fail on exist |
| 69 | queue_name3 = self._get_queue_reference() |
| 70 | created = self.service.create_queue(queue_name3) # True |
| 71 | created = self.service.create_queue(queue_name3) # False |
| 72 | try: |
| 73 | self.service.create_queue(queue_name3, fail_on_exist=True) |
| 74 | except AzureConflictHttpError: |
| 75 | pass |
| 76 | |
| 77 | self.service.delete_queue(queue_name1) |
| 78 | self.service.delete_queue(queue_name2) |
| 79 | self.service.delete_queue(queue_name3) |
| 80 | |
| 81 | def delete_queue(self): |
no outgoing calls