diff --git a/members/rest-queued/src/main.rs b/members/rest-queued/src/main.rs index 1bdfb01..9340750 100644 --- a/members/rest-queued/src/main.rs +++ b/members/rest-queued/src/main.rs @@ -7,7 +7,7 @@ //! This way, we have a distribution api, that clients can use to get any messages they have not //! yet received. -use libpt::log::{debug, info}; +use libpt::log::info; mod routes; use routes::*; diff --git a/members/rest-queued/src/store.rs b/members/rest-queued/src/store.rs index b561a25..dc89221 100644 --- a/members/rest-queued/src/store.rs +++ b/members/rest-queued/src/store.rs @@ -51,10 +51,7 @@ impl Item { let seq = SEQUENCE.load(std::sync::atomic::Ordering::Relaxed); SEQUENCE.store(seq + 1, std::sync::atomic::Ordering::Relaxed); - Self { - body: msg, - seq, - } + Self { body: msg, seq } } }