KpokPatagon.Queue.Nats
10.2.26116.1
dotnet add package KpokPatagon.Queue.Nats --version 10.2.26116.1
NuGet\Install-Package KpokPatagon.Queue.Nats -Version 10.2.26116.1
<PackageReference Include="KpokPatagon.Queue.Nats" Version="10.2.26116.1" />
<PackageVersion Include="KpokPatagon.Queue.Nats" Version="10.2.26116.1" />
<PackageReference Include="KpokPatagon.Queue.Nats" />
paket add KpokPatagon.Queue.Nats --version 10.2.26116.1
#r "nuget: KpokPatagon.Queue.Nats, 10.2.26116.1"
#:package KpokPatagon.Queue.Nats@10.2.26116.1
#addin nuget:?package=KpokPatagon.Queue.Nats&version=10.2.26116.1
#tool nuget:?package=KpokPatagon.Queue.Nats&version=10.2.26116.1
Kpok Patagon Framework
Services for publishing and consuming messages to and from NATS JetStream queue services.
Abstracts
This library provides access to queue services provided by a NATS server.
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.
In the appsettings.json, set the NATS server Url for example:
{
"KpokPatagon" : {
"Queue": {
Url: "nats://127.0.0.1:4222"
}
}
}
Service registration
The queue service must be registered with DI within the "configure service" method, for example:
services.AddKpokPatagon(configuration)
.AddNatsQueueService()
;
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
- KpokPatagon.Queue (>= 10.2.26116.1)
- NATS.Net (>= 2.7.3)
-
net8.0
- KpokPatagon.Queue (>= 10.2.26116.1)
- NATS.Net (>= 2.7.3)
-
net9.0
- KpokPatagon.Queue (>= 10.2.26116.1)
- NATS.Net (>= 2.7.3)
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 |
|---|---|---|
| 10.2.26116.1 | 130 | 5/6/2026 |
| 10.2.26104.1 | 127 | 4/14/2026 |
| 10.2.26103.1 | 133 | 4/13/2026 |
| 10.2.26093.1 | 134 | 4/3/2026 |
| 10.2.26092.1 | 131 | 4/2/2026 |
| 10.2.26091.3 | 125 | 4/1/2026 |
| 10.1.26091.2 | 125 | 4/1/2026 |
| 10.1.26091.1 | 122 | 4/1/2026 |
| 10.1.26076.1 | 129 | 3/17/2026 |
| 10.1.26043.1 | 138 | 2/12/2026 |
| 10.1.25347.2 | 235 | 12/13/2025 |
| 10.1.25347.1 | 182 | 12/13/2025 |
| 10.1.25331.1 | 192 | 11/28/2025 |
| 10.0.25325.1 | 337 | 11/21/2025 |
| 10.0.25324.1 | 385 | 11/21/2025 |
| 10.0.25318.1 | 302 | 11/14/2025 |
| 10.0.25317.1 | 333 | 11/13/2025 |
| 10.0.25282.1 | 235 | 10/9/2025 |