From 6992f59cafa495dd66c86f8549c25680901ffb83 Mon Sep 17 00:00:00 2001 From: Owen Nelson Date: Wed, 9 Aug 2023 18:04:36 -0700 Subject: [PATCH] fixup Delivery::nack This was delegating to `Acker::ack` instead of `Acker::nack` --- omniqueue/src/queue/mod.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/omniqueue/src/queue/mod.rs b/omniqueue/src/queue/mod.rs index da39edc..1706356 100644 --- a/omniqueue/src/queue/mod.rs +++ b/omniqueue/src/queue/mod.rs @@ -54,7 +54,7 @@ pub trait QueueBackend { } } -/// The output of qll ueue backends +/// The output of queue backends pub struct Delivery { pub(crate) payload: Option>, @@ -73,7 +73,7 @@ impl Delivery { /// nature of this will vary by backend, but usually it ensures that the same message is either /// reinserted into the same queue or is sent to a separate collection. pub async fn nack(mut self) -> Result<(), QueueError> { - self.acker.ack().await + self.acker.nack().await } /// This method will deserialize the contained bytes using the configured decoder. If a decoder