YMJake.RocketMQ.Client 5.3.7

.NET 8.0 This package targets .NET 8.0. The package is compatible with this framework or higher.
There is a newer version of this package available.
See the version list below for details. 
dotnet add package YMJake.RocketMQ.Client --version 5.3.7
                    


                    

                
NuGet\Install-Package YMJake.RocketMQ.Client -Version 5.3.7
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package. 
<PackageReference Include="YMJake.RocketMQ.Client" Version="5.3.7" />
For projects that support PackageReference, copy this XML node into the project file to reference the package. 
<PackageVersion Include="YMJake.RocketMQ.Client" Version="5.3.7" />
                    


                            Directory.Packages.props
                        

                    

                
<PackageReference Include="YMJake.RocketMQ.Client" />
                    


                            Project file
For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package. 
paket add YMJake.RocketMQ.Client --version 5.3.7
                    


                    

                
#r "nuget: YMJake.RocketMQ.Client, 5.3.7"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package. 
#:package YMJake.RocketMQ.Client@5.3.7
#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package. 
#addin nuget:?package=YMJake.RocketMQ.Client&version=5.3.7
                    


                            Install as a Cake Addin
                        

                    

                
#tool nuget:?package=YMJake.RocketMQ.Client&version=5.3.7
                    


                            Install as a Cake Tool

RocketMQ C# Client with FIFO Accelerator

License NuGet

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
  • ✅ Lite simple consumer with lite topic subscription
  • ✅ Push consumer with FIFO consume accelerator (Enhanced feature)
  • ✅ Message filtering with Tag and SQL92 expressions (v5.2.8)
  • ✅ Priority Message (v5.3.4)

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 support with W3C Trace Context propagation. See package docs for details. The core YMJake.RocketMQ.Client package now stays lean and does not carry OpenTelemetry metrics/exporter dependencies; tracing and metrics live in the optional OpenTelemetry package.

OpenTelemetry SemConv Alignment

The OpenTelemetry package is aligned with RocketMQ's messaging semantic conventions at the client side:

  • Standard messaging attributes such as messaging.system, messaging.operation.name, messaging.operation.type, and messaging.destination.name
  • RocketMQ-specific attributes such as messaging.consumer.group.name, messaging.rocketmq.namespace, messaging.rocketmq.message.type, messaging.rocketmq.message.tag, messaging.rocketmq.message.group, messaging.rocketmq.message.keys, and messaging.rocketmq.message.delivery_timestamp
  • Client-side metrics for send, delivery, await, and process latency

The implementation intentionally avoids broker-side metrics and labels such as cluster or broker node identifiers. If the core client later exposes stable endpoint/error details in diagnostics, we can optionally extend the instrumentation with additional fields such as server.address, server.port, and error.type.

Examples

See RocketMQ.Client.Examples for sample code.

For a runnable WebAPI demo that exercises tracing with OpenTelemetry, see RocketMQ.Client.OpenTelemetry.Sample.

Java Parity Status

This project is largely aligned with the latest Java client on core messaging paths.

Aligned

  • OffsetOption for Lite Push Consumer
  • Priority Message support (build/send/parse/message type mapping)
  • FIFO message-group load balancing with SipHash24
  • Push FIFO consume accelerator (parallel by message group, ordered within group)
  • LiteSimpleConsumer with lite topic management and lite client type
  • Session.SyncSettings concurrent synchronization
  • Push ACK / ChangeInvisible / DLQ main behavior and logging paths, including lite-topic propagation for ack and change-invisible flows
  • Message filtering with Tag and SQL92 expressions + interceptor filtering flow

Ongoing Parity Improvements

  • OpenTelemetry tracing and metrics detail alignment
  • Minor edge-case log wording and exception-path consistency
  • Builder default/config parity verification across languages

License

Apache License 2.0. Based on Apache RocketMQ Clients.

Packages

Product 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. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

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 - 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.5.5 94 6/14/2026
5.5.4 101 6/4/2026
5.5.3 116 5/25/2026
5.5.2 94 5/25/2026
5.5.1 115 5/25/2026
5.5.0 135 5/20/2026
5.4.6 115 5/7/2026
5.4.5 94 5/7/2026
5.4.4 159 5/7/2026
5.4.3 90 5/7/2026
5.4.2 112 4/23/2026
5.4.1 155 4/21/2026
5.4.0 117 4/6/2026
5.3.10 152 4/5/2026
5.3.9 177 4/5/2026
5.3.8 265 4/3/2026
5.3.7 134 4/3/2026
5.3.5 154 2/24/2026
5.3.4 150 2/24/2026
5.3.3 220 12/13/2025
Loading failed

v5.3.7: Adds LiteSimpleConsumer support, synchronizes lite-topic handling with the latest RocketMQ protocol, and keeps the core client lean.