YMJake.RocketMQ.Client
5.5.2
See the version list below for details.
dotnet add package YMJake.RocketMQ.Client --version 5.5.2
NuGet\Install-Package YMJake.RocketMQ.Client -Version 5.5.2
<PackageReference Include="YMJake.RocketMQ.Client" Version="5.5.2" />
<PackageVersion Include="YMJake.RocketMQ.Client" Version="5.5.2" />
<PackageReference Include="YMJake.RocketMQ.Client" />
paket add YMJake.RocketMQ.Client --version 5.5.2
#r "nuget: YMJake.RocketMQ.Client, 5.5.2"
#:package YMJake.RocketMQ.Client@5.5.2
#addin nuget:?package=YMJake.RocketMQ.Client&version=5.5.2
#tool nuget:?package=YMJake.RocketMQ.Client&version=5.5.2
RocketMQ C# Client
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 — experimental support for RocketMQ 5.5+
- ⚠️ Lite Simple Consumer — client-side API is available, but current RocketMQ 5.5 proxy/server support is still incomplete
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.Samples 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.35.0)
- Grpc.Net.Client (>= 2.80.0)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.7)
- NLog.Extensions.Logging (>= 6.1.3)
- System.IO.Hashing (>= 10.0.8)
-
net8.0
- Google.Protobuf (>= 3.35.0)
- Grpc.Net.Client (>= 2.80.0)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.7)
- NLog.Extensions.Logging (>= 6.1.3)
- System.IO.Hashing (>= 10.0.8)
NuGet packages (6)
Showing the top 5 NuGet packages that depend on YMJake.RocketMQ.Client:
| Package | Downloads |
|---|---|
|
YMJake.RocketMQ.Client.OpenTelemetry
OpenTelemetry instrumentation for YMJake.RocketMQ.Client with publish/process tracing, optional receive telemetry, client-side latency metrics, and broker-controlled OTLP metric export for Apache RocketMQ 5.x. |
|
|
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.5.8 | 77 | 7/11/2026 |
| 5.5.7 | 59 | 7/11/2026 |
| 5.5.6 | 102 | 7/10/2026 |
| 5.5.5 | 117 | 6/14/2026 |
| 5.5.4 | 116 | 6/4/2026 |
| 5.5.3 | 126 | 5/25/2026 |
| 5.5.2 | 103 | 5/25/2026 |
| 5.5.1 | 124 | 5/25/2026 |
| 5.5.0 | 150 | 5/20/2026 |
| 5.4.6 | 125 | 5/7/2026 |
| 5.4.5 | 99 | 5/7/2026 |
| 5.4.4 | 168 | 5/7/2026 |
| 5.4.3 | 99 | 5/7/2026 |
| 5.4.2 | 123 | 4/23/2026 |
| 5.4.1 | 163 | 4/21/2026 |
| 5.4.0 | 122 | 4/6/2026 |
| 5.3.10 | 156 | 4/5/2026 |
| 5.3.9 | 186 | 4/5/2026 |
| 5.3.8 | 269 | 4/3/2026 |
| 5.3.7 | 141 | 4/3/2026 |
v5.5.2: Adds PushConsumer Close/CloseAsync APIs and idempotent shutdown semantics, aligning lifecycle usage with Producer and SimpleConsumer.