YMJake.RocketMQ.Client
5.4.6
dotnet add package YMJake.RocketMQ.Client --version 5.4.6
NuGet\Install-Package YMJake.RocketMQ.Client -Version 5.4.6
<PackageReference Include="YMJake.RocketMQ.Client" Version="5.4.6" />
<PackageVersion Include="YMJake.RocketMQ.Client" Version="5.4.6" />
<PackageReference Include="YMJake.RocketMQ.Client" />
paket add YMJake.RocketMQ.Client --version 5.4.6
#r "nuget: YMJake.RocketMQ.Client, 5.4.6"
#:package YMJake.RocketMQ.Client@5.4.6
#addin nuget:?package=YMJake.RocketMQ.Client&version=5.4.6
#tool nuget:?package=YMJake.RocketMQ.Client&version=5.4.6
RocketMQ C# Client with FIFO Accelerator
Enhanced C# client for Apache RocketMQ 5.x with full feature support and FIFO Consume Accelerator.
Features
- ✅ Producer — normal / FIFO / delay / transactional / recall
- ✅ Simple consumer (pull mode)
- ✅ Push consumer — concurrent / FIFO / FIFO accelerator (enhanced)
- ✅ Message filtering — Tag & SQL92 expressions
- ✅ Priority Message
- ⚠️ Lite Push Consumer / Lite Simple Consumer — client-side only; requires RocketMQ server ≥ 5.5.0 (RIP-83, not yet released)
Supports .NET 8.0 (LTS) and .NET 10.0
Installation
dotnet add package YMJake.RocketMQ.Client
Optional: OpenTelemetry Instrumentation
dotnet add package YMJake.RocketMQ.Client.OpenTelemetry
Automatic distributed tracing and metrics with W3C Trace Context propagation.
See package docs for details.
Examples
See RocketMQ.Client.Examples for sample code.
For a runnable WebAPI demo with OpenTelemetry tracing, see RocketMQ.Client.OpenTelemetry.Sample.
Packages
- Main Client: YMJake.RocketMQ.Client
- OpenTelemetry: YMJake.RocketMQ.Client.OpenTelemetry
- Repository: Gitee
License
Apache License 2.0. Based on Apache RocketMQ Clients.
| 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 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 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
- Google.Protobuf (>= 3.34.1)
- Grpc.Net.Client (>= 2.80.0)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.7)
- NLog.Extensions.Logging (>= 6.1.3)
- System.IO.Hashing (>= 10.0.7)
-
net8.0
- Google.Protobuf (>= 3.34.1)
- Grpc.Net.Client (>= 2.80.0)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.7)
- NLog.Extensions.Logging (>= 6.1.3)
- System.IO.Hashing (>= 10.0.7)
NuGet packages (5)
Showing the top 5 NuGet packages that depend on YMJake.RocketMQ.Client:
| Package | Downloads |
|---|---|
|
YMJake.RocketMQ.Client.OpenTelemetry
OpenTelemetry instrumentation for YMJake.RocketMQ.Client - Automatic distributed tracing for Apache RocketMQ 5.x messaging operations with W3C Trace Context propagation |
|
|
YMJake.AspNetCore.HealthChecks.RocketMQ
ASP.NET Core health checks for Apache RocketMQ. |
|
|
YMJake.Aspire.Apache.RocketMQ
Client-side Aspire helpers for Apache RocketMQ, including optional health checks, logging, tracing, and metrics wiring. |
|
|
YMJake.Aspire.Hosting.RocketMQ
Hosting extensions for running RocketMQ with .NET Aspire. |
|
|
YMJake.Wolverine.RocketMQ
RocketMQ Transport for Wolverine Messaging Systems |
GitHub repositories
This package is not used by any popular GitHub repositories.
| Version | Downloads | Last Updated |
|---|---|---|
| 5.4.6 | 98 | 5/7/2026 |
| 5.4.5 | 87 | 5/7/2026 |
| 5.4.4 | 139 | 5/7/2026 |
| 5.4.3 | 83 | 5/7/2026 |
| 5.4.2 | 98 | 4/23/2026 |
| 5.4.1 | 148 | 4/21/2026 |
| 5.4.0 | 106 | 4/6/2026 |
| 5.3.10 | 144 | 4/5/2026 |
| 5.3.9 | 170 | 4/5/2026 |
| 5.3.8 | 254 | 4/3/2026 |
| 5.3.7 | 118 | 4/3/2026 |
| 5.3.5 | 145 | 2/24/2026 |
| 5.3.4 | 140 | 2/24/2026 |
| 5.3.3 | 212 | 12/13/2025 |
| 5.3.2 | 129 | 12/13/2025 |
| 5.3.1 | 429 | 11/19/2025 |
v5.4.6: Reissues the SimpleConsumer.ForwardToDeadLetterQueue(MessageView, int) API in the published package so consumers can resolve native DLQ forwarding correctly.