| commit | 95305cb1d3b88d016f6abead7d60d70109332fec | [log] [tgz] |
|---|---|---|
| author | Zhanhui Li <lizhanhui@apache.org> | Tue Jun 28 17:26:02 2022 +0800 |
| committer | GitHub <noreply@github.com> | Tue Jun 28 17:26:02 2022 +0800 |
| tree | 1333d2263ab30870681a90fd10e8eef1b8f0763e | |
| parent | f9abf8c5ae278490dd09ee798d3d63672e703d4c [diff] |
Merge back to master (#21) * Refactor ClientManager and RpcClient (#9) * Ensure rpc stub dispose correctly when shutdown (#10) * Transparent retry when query topic route entries * Make sure stub shutdown gracefully * Log when something is wrong (#11) * Supply the residual RPC request (#12) * Fix a series of naming issues (#13) * Implement the first alpha version of PushConsumer, with many TODOs (#14) Implement an initial version of PushConsumer * Polish code (#15) * WIP: Start to adapt to protocol v2 * WIP: debug telemetry bi-direction streaming * Fix telemetry by adding x-mq-client-id header * WIP: * Make producer work * Polish code (#20) * Add package OpenTelemetry and Opentelemetry.API * WIP: write unit tests * WIP * Make Shutdown async * WIP: refactor start procedure * WIP * WIP * WIP: receive messages * WIP: add change invisible duration * Minor fix * Adjust message * Add unit tests for Producer.Send * WIP: prepare to add unit test for SimpleConsumer.Receive * WIP: Unit tests for SimpleConsumer.Receive * Add unit tests for SimpleConsumer * Collect metrics for Producer * Fix minor issue * Add custom otlp exporter * add MeterProvider Co-authored-by: aaron ai <yangkun.ayk@alibaba-inc.com>
Project rocketmq-client-csharp is targeted to implement C# binding in native C# code. At the current moment, it is still a work-in-progress project. Do not use it in production till it grows mature enough.
Basically, this project would follow the same paradigm of rocketmq-client-cpp v5.0.0. Namely, we would build the whole client following protocols described in rocketmq-apis on top of gRPC-dotnet, utilizing Protocol buffers to serialize and deserialize data in transmission.
Layout of this project roughly follows this guide. The solution contains a class library, a unit test module and an example console module.
Assuming you are at the home of this repository,
dotnet build
dotnet test -l "console;verbosity=detailed"
dotnet run -p examples
This project follows Apache License Version 2.0.
Similar to other Apache RocketMQ projects, we welcome contributions in various ways, from filing a bug report, correcting type error, document writing to complete feature implementation. Any attempt to make this project better is welcome.
If this project catches your attention, do not hesitate to make a pull request.