fix: missing redismq missing message

geofmureithi · Dec 5, 2024 · b42056d · b42056d
1 parent b597cf4
commit b42056d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/examples/redis-mq-example/src/main.rs b/examples/redis-mq-example/src/main.rs
@@ -23,6 +23,8 @@ struct RedisMq<T, C = JsonCodec<Vec<u8>>> {
     codec: PhantomData<C>,
 }
 
+type RedisMqMessage<Req> = (Req, RedisMqContext);
+
 #[derive(Clone, Debug, Serialize, Deserialize, Default)]
 pub struct RedisMqContext {
     max_attempts: usize,
@@ -71,7 +73,7 @@ where
                     .map(|r| {
                         let mut req: Request<Req, RedisMqContext> =
                             C::decode(r.message).map_err(Into::into).unwrap();
-                        req.insert(r.id);
+                        req.parts.context.message_id = r.id;
                         req
                     });
                 tx.send(Ok(msg)).await.unwrap();