docs: removed consumer name
This commit is contained in:
parent
9334050ab9
commit
de6c0619b3
|
@ -35,7 +35,7 @@ Get directly from crates.io
|
||||||
|
|
||||||
```toml
|
```toml
|
||||||
[dependencies]
|
[dependencies]
|
||||||
bunbun-worker = { version = "0.1.0" }
|
bunbun-worker = { version = "0.1.1" }
|
||||||
```
|
```
|
||||||
|
|
||||||
or get it directly from source
|
or get it directly from source
|
||||||
|
@ -106,7 +106,6 @@ async fn main(){
|
||||||
listener
|
listener
|
||||||
.add_rpc_consumer::<EmailJob>(
|
.add_rpc_consumer::<EmailJob>(
|
||||||
"email-emailjob-v1.0.0", // queue name
|
"email-emailjob-v1.0.0", // queue name
|
||||||
"emailjob", // consumer tag
|
|
||||||
State {
|
State {
|
||||||
something: "test".into(), // putting our state into a Arc<Mutex<S>> for thread safety
|
something: "test".into(), // putting our state into a Arc<Mutex<S>> for thread safety
|
||||||
},
|
},
|
||||||
|
|
Loading…
Reference in a new issue