Skip to content

Commit

Permalink
Merge pull request #16 from svix/onelson/bridge-fitting
Browse files Browse the repository at this point in the history
make `Acker` require `Send+Sync`, re-export redis connection manager
  • Loading branch information
svix-onelson authored Aug 15, 2023
2 parents fbb64b1 + ffd0d6a commit c651841
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion omniqueue/src/backends/redis/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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::{
Expand Down
2 changes: 1 addition & 1 deletion omniqueue/src/queue/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,7 @@ impl Delivery {
}

#[async_trait]
pub trait Acker {
pub trait Acker: Send + Sync {
async fn ack(&mut self) -> Result<(), QueueError>;
async fn nack(&mut self) -> Result<(), QueueError>;
}
Expand Down

0 comments on commit c651841

Please sign in to comment.