22 lines
408 B
Go
22 lines
408 B
Go
package main
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/hibiken/asynq"
|
|
"gitnet.fr/deblan/golang-worker/task/foo"
|
|
)
|
|
|
|
const redisAddr = "127.0.0.1:6379"
|
|
|
|
func main() {
|
|
client := asynq.NewClient(asynq.RedisClientOpt{Addr: redisAddr})
|
|
defer client.Close()
|
|
|
|
for {
|
|
task, _ := foo.NewFooTask(time.Now(), "foo")
|
|
client.Enqueue(task, asynq.MaxRetry(10), asynq.Timeout(3*time.Minute))
|
|
|
|
time.Sleep(1 * time.Second)
|
|
}
|
|
}
|