# 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())
# Packages
No description provided by the author
No description provided by the author
Copyright © 2022 NAME HERE <EMAIL ADDRESS>
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
No description provided by the author