delay-queue-client

delay-queue client in Golang. It is the SDK written in Golang for https://github.com/changsongl/delay-queue

How to use?

package main
import (
    "fmt"
    "github.com/changsongl/delay-queue-client/client"
    "github.com/changsongl/delay-queue-client/consumer"
    "github.com/changsongl/delay-queue-client/job"
    "time"
)
func main() {
    // job object
    myTopic, myID := "my-topic", "my-id"
    j, err := job.New(myTopic, myID, job.DelayOption(2*time.Second), job.TTROption(30*time.Second))
    if err != nil {
        panic(err)
    }
    // client
    cli := client.NewClient("127.0.0.1:8000")
    // adding job to delay queue, if job is exist will be failed
    if err = cli.AddJob(j); err != nil {
        panic(err)
    }
    // replace the job, even if the job is exists
    if err = cli.ReplaceJob(j); err != nil {
        panic(err)
    }
    // delete the job
    if err = cli.DeleteJob(myTopic, myID); err != nil {
        panic(err)
    }
    // pop the job from queue, no recommended. please use consumer.
    topic, id, body, delay, ttr, err := cli.PopJob(myTopic, 3*time.Second)
    if err != nil {
        panic(err)
    }
    fmt.Println(topic, id, body, delay, ttr)
    // finish the job, after having processed the job
    if err = cli.FinishJob(myTopic, myID); err != nil {
        panic(err)
    }
    // consumer jobs
    c := consumer.New(
        cli,
        topic,
        consumer.WorkerNumOption(1),
        consumer.PopTimeoutOption(3*time.Second),
    )
    ch := c.Consume()
    for jobMsg := range ch {
        id := jobMsg.GetID()
        body := jobMsg.GetBody()
        // do your job
        fmt.Println(id, body)
        if id == "xxx" {
            // job is not valid anymore
            if err = jobMsg.Finish(); err != nil {
                // do something
            }
            continue
        }
        if err = jobMsg.Finish(); err != nil {
            // do something
        }
    }
}