example_client_test.go

// Copyright (c) 2019 Sick Yoon
// This file is part of gocelery which is released under MIT license.
// See file LICENSE for full license details.

package gocelery

import (
	"context"
	"log"
	"math/rand"
	"reflect"
	"time"

	"github.com/redis/go-redis/v9"
)

func Example_client() {
	connectOpions, err := redis.ParseURL("redis://")
	if err != nil {
		panic(err)
	}

	client := redis.NewClient(connectOpions)

	// initialize celery client
	cli, _ := NewCeleryClient(
		NewRedisBroker(client),
		&RedisCeleryBackend{UniversalClient: client},
		1,
	)

	// prepare arguments
	taskName := "worker.add"
	argA := rand.Intn(10)
	argB := rand.Intn(10)

	task := GetTaskMessage(taskName)
	task.Args = append(task.Args, argA, argB)

	// run task
	asyncResult, err := cli.Delay(context.Background(), task)
	if err != nil {
		panic(err)
	}

	// get results from backend with timeout
	res, err := asyncResult.Get(context.Background(), 10*time.Second)
	if err != nil {
		panic(err)
	}

	log.Printf("result: %+v of type %+v", res, reflect.TypeOf(res))

}