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)
	}
}