Skip to content

jojomak13/QueueBolt

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

2 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

QueueBolt

package main

import (
	"time"

	"github.com/go-redis/redis/v8"
	bolt "github.com/jojomak13/QueueBolt"
)

func main() {
	queue := bolt.NewQueue(redis.Options{
		Addr: "localhost:6379",
	}, 1)

	queue.Run()

	queue.Add(bolt.Job{
		ID:        "3248932489",
		Payload:   "welcome jojo",
		ExecuteAt: time.Now().Add(time.Second * 2).Unix(),
	})

	queue.Add(bolt.Job{
		ID:        "32489",
		Payload:   "welcome jojo again",
		ExecuteAt: time.Now().Add(time.Second * 4).Unix(),
	})

	select {
	//
	}
}

About

No description, website, or topics provided.

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages