{"repo":"HDT3213/delayqueue","free":true,"listed":false,"github":"https://github.com/HDT3213/delayqueue","clone":"git clone https://github.com/HDT3213/delayqueue.git","description":"Simple, reliable, installation-free distributed delayed delivery message queue in Go. 简单、可靠、免安装的分布式延时投递消息队列","language":"Go","stars":391,"topics":["delay-queue","delayed-job","golang","message-queue","redis"],"license":"Apache-2.0","category":"databases-storage","readme_excerpt":"DelayQueue 中文版 DelayQueue is a message queue supporting delayed/scheduled delivery based on redis. It is designed to be reliable, scalable and easy to get started. Core Advantages: - Guaranteed at least once consumption - Auto retry failed messages - Works out of the box, Config Nothing and Deploy Nothing, A Redis is all you need. - Natively adapted to the distributed environment, messages processed concurrently on multiple machines . Workers can be added, removed or migrated at any time - Support Redis Cluster or clusters of most cloud service providers. see chapter Cluster - Easy to use monitoring data exporter, see Monitoring Install DelayQueue requires a Go version with modules support. Run following command line in your project with go.mod: if you are using github.com/go-redis/redis/v8 please use go get github.com/hdt3213/delayqueue@redisv8 Get Started SendScheduleMsgV2 ( SendDelayMsgV2 ) is fully compatible with SendScheduleMsg ( SendDelayMsg ) Please note that redis/v8 is not compatible with redis cluster 7.x. detail If you are using redis client other than go-redis, you could wrap your redis client into RedisCli interface If you don't want to set the callback during initialization, you can use func WithCallback . Producer consumer distributed deployment By default, delayqueue instances can be both producers and consumers. If your program only need producers and consumers are placed elsewhere, delayqueue.NewPublisher is a good option for you. Intercept/Delete Messages ","default_branch":null,"files":null,"tree":[],"storefront":"/r/HDT3213","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/HDT3213/delayqueue/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}