search
Found 14 packages
pkg
DelayQueue.Redis
A delay queue based on redis
v0.1.8
↙ 4.3K / total
DelayQueue延时队列DelayQueueRedisQueue
pkg
DelayQueue.Core
Redis's distributed delay queue middleware supports Redis Cluster, handling billions of messages and offering dynamic load balancing. It also supports features such as second-level delay, message ACK, consumption failure retry, dead letter queue, early consumption of messages, and backlog consumption of messages.
v3.0.2
↙ 3.7K / total
DelayQueueDelayQueueRedisDelayed
pkg
DelayQueue.Net
延时队列，参考Java DelayQueue实现。 v1.0.2更新内容： 1、添加默认延时对象DelayItem。 v1.0.3更新内容： 1、优化入队出队的校验逻辑。
v1.0.3
↙ 9.8K / total
pkg
DelayQueues
C#延时队列，定时任务(支持Cron表达式)，不支持分布式，支持失败重试，支持设置失败次数
v1.0.8
↙ 2.3K / total
DelayQueueDelayTaskDelayQueueSchedule(Support
pkg
MooseSoft.Azure.ServiceBus
Provides support for advanced message processing scenarios using Microsoft Azure Service Bus, including retry with back off delay handling through failure policies.
v3.1.0
↙ 36.3K / total
azureservicebusretrydelay
pkg
Moosesoft.Azure.Messaging.ServiceBus
Provides support for advanced message processing scenarios using Microsoft Azure Service Bus, including retry with back off delay handling through failure policies.
v1.1.0
↙ 32.6K / total
azureservicebusservicebusretry
ShareInvest.Delay.Task
Delay The Task
v1.0.1.1
↙ 883 / total
TaskDelayQueueMQ
pkg
Moosesoft.Azure.Webjobs.Extensions.ServiceBus
Provides Azure Functions In-process Model Service Bus trigger support for handling transient exceptions with failure policies that use delay calculator strategies to delay further message processing on retry attempts.
v1.1.0
↙ 12.7K / total
azurefunctionwebjobtriggerservicebus
OneAutomataMessagingClient
OneAutomata Messaging Client is the latest messaging queue library that works with centralized messaging. Send emails, iCal events, FTP files, web service calls and tweets to the messaging queue for immediate or delayed delivery. Requires OneAutomata Web (FREE) to store and receive messages, view messaging queue, delay delivery of messages, pause, or stop delivery of messages, view email delivery replies and more.
v5.1.1
↙ 47.9K / total
OneAutomataMessagingQueueMessageClient
pkg
Moosesoft.Azure.Functions.Worker.Extensions.ServiceBus
Provides Azure Functions Isolated Worker Model Service Bus trigger support for handling transient exceptions with failure policies that use delay calculator strategies to delay further message processing on retry attempts.
v1.0.0
↙ 10.5K / total
azurefunctionworkerisolatedtrigger
pkg
MiniScheduler
简单的调度程序，定时任务(支持Cron表达式)，延时队列，不支持分布式，支持失败重试，支持设置失败次数 A simple scheduler, timed tasks (supports Cron expressions), delayed queues, does not support distributed, delayed queues support failure retry, support for setting the number of failures
v1.0.12
↙ 1.1K / total
DelayQueueDelayTaskDelayQueueSchedule(Support
DotBPE.Extra.Pipeline
base on DotBPE and Foundatio, a lightweight queue task and delay task lib
v1.2.1
↙ 8.9K / total
microservicedotnetpeachrpcdotbpe
pkg
jack
jack is a beanstalkd (http://kr.github.io/beanstalkd/) client written in F#. Install: nuget install jack Usage: open jack let client = Connection.parseAddress "localhost:11300" |> Client.connect client.useTube "testTube" |> ignore client.put 1000 0 30 "my message" |> ignore // priority=1000, delay=0, ttr=30 seconds client.watch "testTube" |> ignore let result = client.reserveWithTimeout 5 match result with | Success (jobId, payload) -> printfn "jobId=%i payload=%s" jobId payload client.delete jobId |> ignore | Failure msg -> failwith msg
v1.0.1
↙ 4.4K / total
beanstalkdbeanstalkmessagequeue
pkg
SimpleServiceBus
A messaging library for publish-subscribe implementation on top of MSMQ. Supports transactional and non-transactional queues, dead letter queue and automatic retries with delay between failed attempts. Aims to provides a reliable yet very simple way to integrate applications running on the same machine or across networks.
v1.0.0
↙ 1.8K / total
messagingservicebusmsmq