Categorygithub.com/puper/nats-delayqueue
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())