4o1x5/bunbun-worker
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Docs...

Browse source
This commit is contained in:
2005 2024-11-15 23:18:07 +01:00
parent e68c88ad60
commit d6c41713b9
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/lib.rs
View file

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