HyperBulk 1.0.0
dotnet add package HyperBulk --version 1.0.0
NuGet\Install-Package HyperBulk -Version 1.0.0
<PackageReference Include="HyperBulk" Version="1.0.0" />
<PackageVersion Include="HyperBulk" Version="1.0.0" />
<PackageReference Include="HyperBulk" />
paket add HyperBulk --version 1.0.0
#r "nuget: HyperBulk, 1.0.0"
#:package HyperBulk@1.0.0
#addin nuget:?package=HyperBulk&version=1.0.0
#tool nuget:?package=HyperBulk&version=1.0.0
HyperBulk
RabbitMQ Bulk Consumer with Polly Retry mechanism and RabbitMQ deadletter
Usage
Creaye your class inherited from BulkConsumer
Override Received method
In this method you can do whatever you want to do. Api call or start another process.
Do not use try catch inside the method. because polly will take care of it for you.

ConsumerSettings
AppSettings.ConsumeDelay ⇒ You say that the application should process the data it collects at intervals of how many seconds.
AppSettings.ReconnectCount ⇒ If the app crashes, how many times should it try to run it again? if you set it to 0 it will try infinite times. If you enter a certain number, it will automatically close the application when it reaches that number.
AppSettings.ReconnectDelay ⇒ you tell the application how long (in seconds) it should wait for it to run again.
RabbitMQSettings ⇒ Check rabbitmq offical website
RabbitMQSettings.PrefetchOrigins ⇒ In cases where the number of queues is greater than "Key" in the dictionary object you sent, you replace the prefetch count property with the "Value" value. So you balance the consume state.
RetrySettings.Count ⇒ Specifies how many times to try again if the method you override gets an error.
RetrySettings.Delay ⇒ The time (in seconds) between each new attempt is given when the method receives an error. performs the next attempt by multiplying the number of errors by the given second.
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net6.0 is compatible. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 was computed. 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. net9.0 was computed. net9.0-android was computed. net9.0-browser was computed. net9.0-ios was computed. net9.0-maccatalyst was computed. net9.0-macos was computed. net9.0-tvos was computed. net9.0-windows was computed. net10.0 was computed. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed. |
-
net6.0
- Newtonsoft.Json (>= 13.0.2)
- Polly (>= 7.2.3)
- RabbitMQ (>= 3.6.2)
- RabbitMQ.Client (>= 6.4.0)
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 |
|---|---|---|
| 1.0.0 | 345 | 12/6/2022 |