mirror of
https://github.com/acaloiaro/neoq
synced 2026-07-21 18:29:08 +00:00
Use WithOption
This commit is contained in:
parent
d253b50a58
commit
da96409f30
1 changed files with 1 additions and 1 deletions
|
|
@ -35,7 +35,7 @@ func main() {
|
|||
})
|
||||
|
||||
// this 10ms deadline will cause our job that sleeps for 1s to fail
|
||||
handler = handler.WithOpt(neoq.HandlerDeadline(10 * time.Millisecond))
|
||||
handler = handler.WithOption(neoq.HandlerDeadline(10 * time.Millisecond))
|
||||
|
||||
err = nq.Listen(ctx, queue, handler)
|
||||
if err != nil {
|
||||
|
|
|
|||
Loading…
Reference in a new issue