starred/minne
1
0
Fork 0
mirror of https://github.com/perstarkse/minne.git synced 2026-03-12 21:35:40 +01:00
Code Issues Packages Projects Releases 10 Wiki Activity

fix: resolve compilation errors in rabbitmq module by correcting async function return types and method calls

Browse Source
This commit is contained in:
Per Stark" (aider)
2024-09-18 12:24:32 +02:00
parent b6e06779f9
commit 30de906ee6
1 changed files with 16 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/rabbitmq/mod.rs
View File

@@ -37,10 +37,10 @@ impl RabbitMQ {
}
pub async fn declare_queue(&self, queue_name: &str) -> Result<(String, u32, u32), Box<dyn std::error::Error>> {
Ok(self.channel
self.channel
.queue_declare(QueueDeclareArguments::durable_client_named(queue_name))
.await??
)
.await?
.ok_or_else(|| Box::new(std::io::Error::new(std::io::ErrorKind::Other, "Failed to declare queue")) as Box<dyn std::error::Error>)
}
pub async fn bind_queue(&self, queue_name: &str, exchange_name: &str, routing_key: &str) -> Result<(), Box<dyn std::error::Error>> {
@@ -62,17 +62,21 @@ impl RabbitMQ {
let (tx, rx) = mpsc::channel(100);
let args = BasicConsumeArguments::new(queue_name, consumer_tag);
let consumer = DefaultConsumer::new(args.no_ack).with_callback(move |_deliver, _basic_properties, content| {
let content_str = String::from_utf8_lossy(&content).to_string();
let tx = tx.clone();
tokio::spawn(async move {
if let Err(e) = tx.send(content_str).await {
eprintln!("Failed to send message: {}", e);
}
let consumer = DefaultConsumer::new(args.no_ack);
let tx_clone = tx.clone();
self.channel.basic_consume(consumer, args)
.await?
.set_delegate(move |deliver: amqprs::consumer::DeliverEvent| {
let content_str = String::from_utf8_lossy(&deliver.content).to_string();
let tx = tx_clone.clone();
tokio::spawn(async move {
if let Err(e) = tx.send(content_str).await {
eprintln!("Failed to send message: {}", e);
}
});
});
});
self.channel.basic_consume(consumer, args).await?;
Ok(rx)
}
}