feat: implement RabbitMQ connection and queue management in new module

This commit is contained in:
Per Stark
2024-09-18 12:20:01 +02:00
committed by Per Stark" (aider)
commit bb3ed4b034
3 changed files with 727 additions and 0 deletions

10
src/server.rs Normal file
View File

@@ -0,0 +1,10 @@
use zettle_db::rabbitmq::RabbitMQ;
#[tokio::main(flavor = "multi_thread", worker_threads = 2)]
async fn main() {
let rabbitmq = RabbitMQ::new().await;
let queue_name = rabbitmq.declare_queue("amqprs.examples.basic").await;
rabbitmq.bind_queue(&queue_name.0, "amq.topic", "amqprs.example").await;
//...
}