| 248 | self.service.delete_queue(queue_name) |
| 249 | |
| 250 | def list_queues(self): |
| 251 | queue_name1 = self._get_queue_reference() |
| 252 | self.service.create_queue('queue1', metadata={'val1': 'foo', 'val2': 'blah'}) |
| 253 | |
| 254 | queue_name2 = self._create_queue('queue2') |
| 255 | queue_name3 = self._create_queue('thirdq') |
| 256 | |
| 257 | # Basic |
| 258 | # Commented out as this will list every queue in your account |
| 259 | # queues = list(self.service.list_queues()) |
| 260 | # for queue in queues: |
| 261 | # print(queue.name) # queue1, queue2, thirdq, all other queues created in the self.service |
| 262 | |
| 263 | # Num results |
| 264 | # Will return in alphabetical order. |
| 265 | queues = list(self.service.list_queues(num_results=2)) |
| 266 | for queue in queues: |
| 267 | print(queue.name) # queue1, queue2, or whichever 2 queues are alphabetically first in your account |
| 268 | |
| 269 | # Prefix |
| 270 | queues = list(self.service.list_queues(prefix='queue')) |
| 271 | for queue in queues: |
| 272 | print(queue.name) # queue1, queue2, and any other queues in your account with this prefix |
| 273 | |
| 274 | # Metadata |
| 275 | queues = list(self.service.list_queues(prefix='queue', include_metadata=True)) |
| 276 | queue = next((q for q in queues if q.name == 'queue1'), None) |
| 277 | metadata = queue.metadata # {'val1': 'foo', 'val2': 'blah'} |
| 278 | |
| 279 | self.service.delete_queue(queue_name1) |
| 280 | self.service.delete_queue(queue_name2) |
| 281 | self.service.delete_queue(queue_name3) |
| 282 | |
| 283 | def alternative_encoding(self): |
| 284 | queue_name = self._create_queue() |