repositorypackage
1.0.0
Repository: https://github.com/puper/nats-delayqueue.git
Documentation: pkg.go.dev
# Packages
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# README
a delayqueue sidecar for nats' jetstream
usage
- create delay stream and consumer manually.
- update config/config.toml
- go run main.go serve --config=config/config.toml
- send msg as you do before but sent to the delayqueue
msg := &protos.DelayMessage{
Ts: time.Now().Unix() + 10, // the timestamp you want to receive this msg
Subject: "test", // the subject in jetstream you want to receive this msg
Data: []byte("123456"),
}
js.Publish("delayqueue", msg.Encode())