diff --git a/src/lib.rs b/src/lib.rs index 8a96f33..e581e21 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -141,6 +141,8 @@ impl ListenerConfig { self.consumer_tag = consumer_tag.into(); self } + + /// Set the message version (eg queue_name-v1.0.0) pub fn set_message_version(mut self, version: impl Into) -> Self { self.message_version = version.into(); self @@ -604,6 +606,7 @@ pub trait Task: Sized + Debug + DeserializeOwned { Ok(job) } + // TODO Attribute-Based Extraction /// The method that will be run by the worker fn run(self, state: Arc) -> BoxFuture<'static, Result<(), ()>>;