(queue_suffix)
| 125 | |
| 126 | @staticmethod |
| 127 | def _get_queue(queue_suffix): |
| 128 | queue_name = queue_utils.get_queue_name( |
| 129 | queue_name_base="st2.sensor.watch", |
| 130 | queue_name_suffix=queue_suffix, |
| 131 | add_random_uuid_to_suffix=True, |
| 132 | ) |
| 133 | return reactor.get_sensor_cud_queue(queue_name, routing_key="#") |