WIP: making changes to help adoption in bridge easier

This stuff is still up in the air. Just trying to pragmatically satisfy the original generic-queue usages in bridge.
svix · Aug 14, 2023 · 8ccc6b3 · 8ccc6b3
1 parent fbb64b1
commit 8ccc6b3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -59,7 +59,7 @@ pub struct Delivery {
     pub(crate) payload: Option<Vec<u8>>,
 
     pub(crate) decoders: DecoderRegistry<Vec<u8>>,
-    pub(crate) acker: Box<dyn Acker>,
+    pub(crate) acker: Box<dyn Acker + Send + Sync>,
 }
 
 impl Delivery {