KpokPatagon.Queue
10.2.26116.1
dotnet add package KpokPatagon.Queue --version 10.2.26116.1
NuGet\Install-Package KpokPatagon.Queue -Version 10.2.26116.1
<PackageReference Include="KpokPatagon.Queue" Version="10.2.26116.1" />
<PackageVersion Include="KpokPatagon.Queue" Version="10.2.26116.1" />
<PackageReference Include="KpokPatagon.Queue" />
paket add KpokPatagon.Queue --version 10.2.26116.1
#r "nuget: KpokPatagon.Queue, 10.2.26116.1"
#:package KpokPatagon.Queue@10.2.26116.1
#addin nuget:?package=KpokPatagon.Queue&version=10.2.26116.1
#tool nuget:?package=KpokPatagon.Queue&version=10.2.26116.1
Kpok Patagon Framework
Services for publishing and consuming messages to and from queue services.
Abstracts
This library provides the abstracts and interfaces to access queue services in a consistent manner.
The feature for using queue services is implemented using this library and other secondary ones for each supported queue service.
KpokPatagon.Queue: this library which provides the definicion and common services.KpokPatagon.Queue.Nats: Provides the functionality to use NATS JetStream services as a message queue service.KpokPatagon.Queue.RabbitMQ: Provides the functionality to use RabbitMQ as a message queue service.
To use the queue features, install the desired NuGet package.
Configuration
Queue services are configured within the KpokPatagon:Queue section in appsettings.json, but the actual key can be specified, if required, as an argument in the registration method.
The configuration for both supported services is the same, the service Url that must include: the protocol, the host name or IP address and if required port, user and password as required by each service, for example:
{
"KpokPatagon" : {
"Queue": {
Url: "protocol://host-or-ip:port"
}
}
}
Service registration
The queue service must be registered with DI within the "configure service" method, for example:
services.AddKpokPatagon(configuration)
.Add???QueueService()
;
Service usage
Once registered just inject the service where required:
readonly IQueusService _queueService;
public MyClass(IQueueService queueService)
{
_queueService = queueService;
}
async Task PublishMessageAsync(MyMessage message)
{
await _queueService.PublishAsync("my-queue", message);
}
async Task ConsumeAsync()
{
await _queueService.ConsumeAsync<MyMessage>("my-queue",
(msg) => { /* Message procesing... */ },
(exception) => { /* Handle errors */ }
);
}
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net8.0 is compatible. 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 is compatible. 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 is compatible. 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. |
-
net10.0
- Microsoft.Extensions.Configuration (>= 10.0.5)
- Microsoft.Extensions.Configuration.Binder (>= 10.0.5)
- Microsoft.Extensions.Configuration.Json (>= 10.0.5)
- Microsoft.Extensions.Logging (>= 10.0.5)
- Microsoft.Extensions.Logging.Configuration (>= 10.0.5)
- Microsoft.Extensions.Options (>= 10.0.5)
- Microsoft.Extensions.Options.DataAnnotations (>= 10.0.5)
-
net8.0
- Microsoft.Extensions.Configuration (>= 10.0.5)
- Microsoft.Extensions.Configuration.Binder (>= 10.0.5)
- Microsoft.Extensions.Configuration.Json (>= 10.0.5)
- Microsoft.Extensions.Logging (>= 10.0.5)
- Microsoft.Extensions.Logging.Configuration (>= 10.0.5)
- Microsoft.Extensions.Options (>= 10.0.5)
- Microsoft.Extensions.Options.DataAnnotations (>= 10.0.5)
- System.Text.Json (>= 10.0.5)
-
net9.0
- Microsoft.Extensions.Configuration (>= 10.0.5)
- Microsoft.Extensions.Configuration.Binder (>= 10.0.5)
- Microsoft.Extensions.Configuration.Json (>= 10.0.5)
- Microsoft.Extensions.Logging (>= 10.0.5)
- Microsoft.Extensions.Logging.Configuration (>= 10.0.5)
- Microsoft.Extensions.Options (>= 10.0.5)
- Microsoft.Extensions.Options.DataAnnotations (>= 10.0.5)
- System.Text.Json (>= 10.0.5)
NuGet packages (2)
Showing the top 2 NuGet packages that depend on KpokPatagon.Queue:
| Package | Downloads |
|---|---|
|
KpokPatagon.Queue.Nats
Services for publishing messages to and consuming messages from NATS services. |
|
|
KpokPatagon.Queue.RabbitMQ
Services for publishing messages to and consuming messages from RabbitMQ services. |
GitHub repositories
This package is not used by any popular GitHub repositories.
| Version | Downloads | Last Updated |
|---|---|---|
| 10.2.26116.1 | 164 | 5/6/2026 |
| 10.2.26104.1 | 158 | 4/14/2026 |
| 10.2.26103.1 | 162 | 4/13/2026 |
| 10.2.26093.1 | 161 | 4/3/2026 |
| 10.2.26092.1 | 156 | 4/2/2026 |
| 10.2.26091.3 | 153 | 4/1/2026 |
| 10.1.26091.2 | 149 | 4/1/2026 |
| 10.1.26091.1 | 154 | 4/1/2026 |
| 10.1.26076.1 | 159 | 3/17/2026 |
| 10.1.26043.1 | 159 | 2/12/2026 |
| 10.1.25347.2 | 254 | 12/13/2025 |
| 10.1.25347.1 | 191 | 12/13/2025 |
| 10.1.25331.1 | 209 | 11/28/2025 |
| 10.0.25325.1 | 349 | 11/21/2025 |
| 10.0.25324.1 | 409 | 11/21/2025 |
| 10.0.25318.1 | 334 | 11/14/2025 |
| 10.0.25317.1 | 360 | 11/13/2025 |
| 10.0.25282.1 | 248 | 10/9/2025 |