Categorygithub.com/puper/nats-delayqueue
modulepackage
1.0.0
Repository: https://github.com/puper/nats-delayqueue.git
Documentation: pkg.go.dev

# 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