YMJake.RocketMQ.Client
5.3.2
See the version list below for details.
dotnet add package YMJake.RocketMQ.Client --version 5.3.2
NuGet\Install-Package YMJake.RocketMQ.Client -Version 5.3.2
<PackageReference Include="YMJake.RocketMQ.Client" Version="5.3.2" />
<PackageVersion Include="YMJake.RocketMQ.Client" Version="5.3.2" />
<PackageReference Include="YMJake.RocketMQ.Client" />
paket add YMJake.RocketMQ.Client --version 5.3.2
#r "nuget: YMJake.RocketMQ.Client, 5.3.2"
#:package YMJake.RocketMQ.Client@5.3.2
#addin nuget:?package=YMJake.RocketMQ.Client&version=5.3.2
#tool nuget:?package=YMJake.RocketMQ.Client&version=5.3.2
RocketMQ C# Client with FIFO Accelerator
Enhanced C# client for Apache RocketMQ 5.x with full feature support and FIFO Consume Accelerator.
Features
All official RocketMQ 5.x C# features are fully implemented:
- ✅ Producer with standard messages
- ✅ Producer with FIFO messages
- ✅ Producer with timed/delay messages
- ✅ Producer with transactional messages
- ✅ Producer with recalling timed/delay messages
- ✅ Simple consumer (pull mode with
Receive()) - ✅ Push consumer with concurrent message listener
- ✅ Push consumer with FIFO message listener
- ✅ Lite push consumer with dynamic subscription
- ✅ Push consumer with FIFO consume accelerator (Enhanced feature)
- ✅ Message filtering with Tag and SQL92 expressions (v5.2.8)
- ✅ OpenTelemetry distributed tracing (v5.3.0)
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 with W3C Trace Context propagation. See package docs for details.
Examples
See RocketMQ.Client.Examples for sample code.
License
Apache License 2.0. Based on Apache RocketMQ Clients.
Packages
- Main Client: YMJake.RocketMQ.Client
- OpenTelemetry: YMJake.RocketMQ.Client.OpenTelemetry
- Repository: Gitee
| 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
- Crc32.NET (>= 1.2.0)
- Google.Protobuf (>= 3.33.2)
- Grpc.Net.Client (>= 2.71.0)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.1)
- NLog.Extensions.Logging (>= 6.1.0)
- OpenTelemetry (>= 1.14.0)
- OpenTelemetry.Api (>= 1.14.0)
- OpenTelemetry.Exporter.OpenTelemetryProtocol (>= 1.14.0)
-
net8.0
- Crc32.NET (>= 1.2.0)
- Google.Protobuf (>= 3.33.2)
- Grpc.Net.Client (>= 2.71.0)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.1)
- NLog.Extensions.Logging (>= 6.1.0)
- OpenTelemetry (>= 1.14.0)
- OpenTelemetry.Api (>= 1.14.0)
- OpenTelemetry.Exporter.OpenTelemetryProtocol (>= 1.14.0)
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.3.2: Adds lite-topic producer sample, stricter message type validation, multi-address DNS resolution & scheduling refactor. Companion package: YMJake.RocketMQ.Client.OpenTelemetry v1.0.1