From d6c41713b926fe60d8e36e878d0699afec9c37d2 Mon Sep 17 00:00:00 2001 From: 4o1x5 <4o1x5@4o1x5.dev> Date: Fri, 15 Nov 2024 23:18:07 +0100 Subject: [PATCH] Docs... --- src/lib.rs | 3 +++ 1 file changed, 3 insertions(+) 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<(), ()>>;