diff --git a/src/main.rs b/src/main.rs index 52aa3ae..b993502 100644 --- a/src/main.rs +++ b/src/main.rs @@ -9,7 +9,7 @@ use std::sync::{Arc, Mutex}; use chrono::{DateTime, Utc}; use lapin::{Connection, ConnectionProperties, Consumer}; use lapin::message::{Delivery, DeliveryResult}; -use lapin::options::{BasicAckOptions, BasicConsumeOptions, BasicQosOptions}; +use lapin::options::{BasicAckOptions, BasicConsumeOptions, BasicQosOptions, BasicRejectOptions}; use lapin::types::FieldTable; use serde::{Deserialize, Serialize}; use log::{error, info, trace, warn}; @@ -87,12 +87,12 @@ _|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""| {======|_|"""""|_|""""" } } Ok(result) => { - error!("Failed to transcribe {}, Exit code {}", &transcription_request.audio_file_path, result.status.code().unwrap()); + error!("Failed to transcribe {}, Exit code {}", &transcription_request.audio_file_path, result.status.code().unwrap_or_else(|| -99)); error!("Stdout: {}", String::from_utf8_lossy(&result.stdout)); error!("Stderr: {}", String::from_utf8_lossy(&result.stderr)); delete_file(path); - return delivery.ack(BasicAckOptions::default()).await.unwrap(); + return delivery.reject(BasicRejectOptions::default()).await.unwrap(); } Err(error) => { error!("Failed to transcribe {}, {}", &transcription_request.audio_file_path, error);