YMJake.RocketMQ.Client
5.3.3
dotnet add package YMJake.RocketMQ.Client --version 5.3.3
NuGet\Install-Package YMJake.RocketMQ.Client -Version 5.3.3
<PackageReference Include="YMJake.RocketMQ.Client" Version="5.3.3" />
<PackageVersion Include="YMJake.RocketMQ.Client" Version="5.3.3" />
<PackageReference Include="YMJake.RocketMQ.Client" />
paket add YMJake.RocketMQ.Client --version 5.3.3
#r "nuget: YMJake.RocketMQ.Client, 5.3.3"
#:package YMJake.RocketMQ.Client@5.3.3
#addin nuget:?package=YMJake.RocketMQ.Client&version=5.3.3
#tool nuget:?package=YMJake.RocketMQ.Client&version=5.3.3
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
- Ben.Demystifier (>= 0.4.1)
- Crc32.NET (>= 1.2.0)
- Google.Protobuf (>= 3.33.2)
- Grpc.Net.Client (>= 2.71.0)
- Microsoft.Diagnostics.Runtime (>= 3.1.455904)
- 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
- Ben.Demystifier (>= 0.4.1)
- Crc32.NET (>= 1.2.0)
- Google.Protobuf (>= 3.33.2)
- Grpc.Net.Client (>= 2.71.0)
- Microsoft.Diagnostics.Runtime (>= 3.1.455904)
- 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 (1)
Showing the top 1 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 |
GitHub repositories
This package is not used by any popular GitHub repositories.
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