| 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): |
| 82 | # Basic |