mirror of
https://github.com/acaloiaro/neoq
synced 2026-07-21 18:29:08 +00:00
Fix test
This commit is contained in:
parent
1db5b7c557
commit
ee5f061d24
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