diff --git a/omniqueue/src/backends/redis/mod.rs b/omniqueue/src/backends/redis/mod.rs index 3301a47..8b48aa5 100644 --- a/omniqueue/src/backends/redis/mod.rs +++ b/omniqueue/src/backends/redis/mod.rs @@ -2,7 +2,7 @@ use std::{any::TypeId, collections::HashMap, marker::PhantomData}; use async_trait::async_trait; use bb8::ManageConnection; -use bb8_redis::RedisMultiplexedConnectionManager; +pub use bb8_redis::RedisMultiplexedConnectionManager; use redis::streams::{StreamReadOptions, StreamReadReply}; use crate::{ diff --git a/omniqueue/src/queue/mod.rs b/omniqueue/src/queue/mod.rs index 1706356..6e6bf94 100644 --- a/omniqueue/src/queue/mod.rs +++ b/omniqueue/src/queue/mod.rs @@ -59,7 +59,7 @@ pub struct Delivery { pub(crate) payload: Option>, pub(crate) decoders: DecoderRegistry>, - pub(crate) acker: Box, + pub(crate) acker: Box, } impl Delivery {