Method add_queue

crates/hyperqueue/src/server/autoalloc/process.rs:2200–2230

(
            &mut self,
            handler: Box<dyn QueueHandler>,
            queue_builder: QueueBuilder,
        )

        }

        async fn add_queue(
            &mut self,
            handler: Box<dyn QueueHandler>,
            queue_builder: QueueBuilder,
        ) -> QueueId {
            let (mut params, rate_limiter) = queue_builder.build();
            params.name = Some("Queue".to_string());

            let (token, rx) = ResponseToken::new();
            handle_message(
                &mut self.state,
                &self.senders.events,
                AutoAllocMessage::AddQueue {
                    server_directory: PathBuf::from("test"),
                    params,
                    queue_id: None,
                    worker_resources: None,
                    response: token,
                },
            )
            .await;
            let queue_id = rx.await.unwrap().unwrap();

            // A bit hacky, but easier than creating a mock for an external service, as we do in
            // Python.
            let queue = self.state.get_queue_mut(queue_id).unwrap();
            queue.set_handler(handler);
            *queue.limiter_mut() = rate_limiter;

            queue_id
        }

        async fn try_submit(&mut self) {
            perform_submits(&mut self.state, &self.senders)