Rystem.Queue
4.1.8
See the version list below for details.
dotnet add package Rystem.Queue --version 4.1.8
NuGet\Install-Package Rystem.Queue -Version 4.1.8
<PackageReference Include="Rystem.Queue" Version="4.1.8" />
paket add Rystem.Queue --version 4.1.8
#r "nuget: Rystem.Queue, 4.1.8"
// Install Rystem.Queue as a Cake Addin #addin nuget:?package=Rystem.Queue&version=4.1.8 // Install Rystem.Queue as a Cake Tool #tool nuget:?package=Rystem.Queue&version=4.1.8
Queue
You have to configure it in DI BackgroundJobCronFormat is the CRON for background job that checks if Maximum buffer is exceeded or has a retention expired, usually is lesser than or equal of MaximumRetentionCronFormat. MaximumRetentionCronFormat is the CRON for maximum time before to empty the queue and call the IQueueManager<T>. MaximumBuffer is the maximum queue length before to empty the queue and call the IQueueManager<T>.
services.AddMemoryQueue<Sample, SampleQueueManager>(x =>
{
x.MaximumBuffer = 1000;
x.MaximumRetentionCronFormat = "*/3 * * * * *";
x.BackgroundJobCronFormat = "*/1 * * * * *";
});
public class SampleQueueManager : IQueueManager<Sample>
{
public Task ManageAsync(IEnumerable<Sample> items)
{
return Task.CompletedTask;
}
}
For instance, in the example above you have a maximum queue length of 1000, a background job thatc checks every 1 second if there are 1000 or more items or maximum retention period of 3 seconds is expired. after the build you have to warm up
var app = builder.Build();
await app.Services.WarmUpAsync();
and inject to use it
var queue = _serviceProvider.GetService<IQueue<Sample>>()!;
for (int i = 0; i < 100; i++)
await queue.AddAsync(new Sample() { Id = i.ToString() });
In this example, after 1000 elements or 3 seconds the configured actions will be fired and the queue will be emptied.
Stack (Last In First Out)
services.AddMemoryStackQueue<Sample, SampleQueueManager>(x =>
{
x.MaximumBuffer = 1000;
x.MaximumRetentionCronFormat = "*/3 * * * * *";
x.BackgroundJobCronFormat = "*/1 * * * * *";
});
Custom integration
If you want to use a distributed queue like storage queue, or event hub or service bus or event grid, you can write your own integration and configure it.
services.AddQueueIntegration<Sample, SampleQueueManager, YourQueueIntegration>(x =>
{
x.MaximumBuffer = 1000;
x.MaximumRetentionCronFormat = "*/3 * * * * *";
x.BackgroundJobCronFormat = "*/1 * * * * *";
});
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net7.0 is compatible. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. |
-
net7.0
- Rystem.BackgroundJob (>= 4.1.8)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last updated |
---|---|---|
6.0.24 | 81 | 9/11/2024 |
6.0.23 | 92 | 7/18/2024 |
6.0.21 | 88 | 6/18/2024 |
6.0.20 | 94 | 6/16/2024 |
6.0.19 | 82 | 6/14/2024 |
6.0.18 | 77 | 6/14/2024 |
6.0.17 | 89 | 6/14/2024 |
6.0.16 | 77 | 6/10/2024 |
6.0.15 | 81 | 6/9/2024 |
6.0.14 | 98 | 5/24/2024 |
6.0.13 | 93 | 5/23/2024 |
6.0.12 | 77 | 5/23/2024 |
6.0.11 | 91 | 5/20/2024 |
6.0.9 | 86 | 5/20/2024 |
6.0.7 | 75 | 5/18/2024 |
6.0.6 | 95 | 5/10/2024 |
6.0.5 | 88 | 5/10/2024 |
6.0.4 | 90 | 4/3/2024 |
6.0.3 | 93 | 3/25/2024 |
6.0.2 | 1,966 | 3/11/2024 |
6.0.0 | 198 | 11/21/2023 |
6.0.0-rc.6 | 91 | 10/25/2023 |
6.0.0-rc.5 | 69 | 10/25/2023 |
6.0.0-rc.4 | 60 | 10/23/2023 |
6.0.0-rc.3 | 58 | 10/19/2023 |
6.0.0-rc.2 | 65 | 10/18/2023 |
6.0.0-rc.1 | 65 | 10/16/2023 |
5.0.20 | 138 | 9/25/2023 |
5.0.19 | 128 | 9/10/2023 |
5.0.18 | 116 | 9/6/2023 |
5.0.17 | 123 | 9/6/2023 |
5.0.16 | 114 | 9/5/2023 |
5.0.15 | 108 | 9/5/2023 |
5.0.14 | 107 | 9/5/2023 |
5.0.13 | 103 | 9/1/2023 |
5.0.12 | 115 | 8/31/2023 |
5.0.11 | 100 | 8/30/2023 |
5.0.10 | 140 | 8/29/2023 |
5.0.9 | 130 | 8/24/2023 |
5.0.8 | 121 | 8/24/2023 |
5.0.7 | 116 | 8/23/2023 |
5.0.6 | 126 | 8/21/2023 |
5.0.5 | 116 | 8/21/2023 |
5.0.4 | 132 | 8/16/2023 |
5.0.3 | 135 | 8/2/2023 |
5.0.2 | 135 | 8/2/2023 |
5.0.1 | 130 | 8/1/2023 |
5.0.0 | 151 | 7/31/2023 |
4.1.26 | 163 | 7/20/2023 |
4.1.25 | 148 | 7/16/2023 |
4.1.24 | 216 | 6/13/2023 |
4.1.23 | 130 | 6/13/2023 |
4.1.22 | 128 | 5/30/2023 |
4.1.21 | 130 | 5/20/2023 |
4.1.20 | 315,125 | 4/19/2023 |
4.1.19 | 94,863 | 3/20/2023 |
4.1.18 | 189 | 3/20/2023 |
4.1.17 | 182 | 3/17/2023 |
4.1.16 | 180 | 3/16/2023 |
4.1.15 | 181 | 3/15/2023 |
4.1.14 | 751 | 3/9/2023 |
4.1.13 | 195 | 3/7/2023 |
4.1.12 | 237 | 2/10/2023 |
4.1.11 | 259 | 1/26/2023 |
4.1.10 | 284 | 1/22/2023 |
4.1.9 | 276 | 1/20/2023 |
4.1.8 | 272 | 1/18/2023 |
4.1.7 | 263 | 1/18/2023 |
4.1.6 | 260 | 1/17/2023 |
4.1.1 | 286 | 1/4/2023 |
4.1.0 | 270 | 12/30/2022 |
3.0.25 | 280 | 12/21/2022 |
3.0.24 | 303 | 11/18/2022 |
3.0.23 | 305 | 11/18/2022 |
3.0.22 | 303 | 11/15/2022 |
3.0.21 | 295 | 11/14/2022 |
3.0.20 | 326 | 11/13/2022 |
3.0.19 | 348 | 11/2/2022 |
3.0.18 | 331 | 11/2/2022 |
3.0.17 | 355 | 10/29/2022 |
3.0.16 | 346 | 10/29/2022 |
3.0.15 | 361 | 10/29/2022 |
2.0.6 | 392 | 9/20/2022 |
2.0.5 | 381 | 9/20/2022 |
2.0.3 | 409 | 9/20/2022 |
2.0.1 | 468 | 9/13/2022 |
2.0.0 | 393 | 8/19/2022 |
1.1.22 | 436 | 7/30/2022 |
1.1.21 | 397 | 7/29/2022 |
1.1.20 | 392 | 7/29/2022 |
1.1.19 | 418 | 7/29/2022 |
1.1.18 | 422 | 7/27/2022 |
1.1.17 | 423 | 7/27/2022 |
1.1.15 | 416 | 7/25/2022 |
1.1.14 | 417 | 7/25/2022 |
1.1.13 | 406 | 7/22/2022 |
1.1.12 | 397 | 7/19/2022 |
1.1.11 | 419 | 7/19/2022 |
1.1.10 | 415 | 7/19/2022 |
1.1.9 | 436 | 7/19/2022 |
1.1.8 | 408 | 7/18/2022 |
1.1.7 | 431 | 7/18/2022 |
1.1.6 | 395 | 7/18/2022 |
1.0.4 | 421 | 7/17/2022 |
1.0.3 | 414 | 7/17/2022 |
1.0.2 | 419 | 7/12/2022 |
1.0.1 | 477 | 7/12/2022 |
1.0.0 | 432 | 7/8/2022 |
0.10.7 | 431 | 7/8/2022 |
0.9.11 | 410 | 7/1/2022 |
0.9.10 | 413 | 6/29/2022 |
0.9.9 | 423 | 6/29/2022 |