rocketmq-clients

• adapt with rocketmq-apis
• add producer/push consumer/simple consumer
• support NORMAL/FIFO/DELAY/TRANSACTION message
• OpenTelemetry metrics support

Changes
1. Support build with CMake;
2. Once receive message actions are throttled, retry after 20ms;
3. If ack/change-invisible-duration/forward-to-dlq failed unexpectedly(aka, not caused by invalid receipt handle), retry 1s later until it succeeds or receipt-handle is rejected;
4. For receive message API, relax an extra 500ms in terms of RPC timeout;

Release 5.0.0-beta of RocketMQ SDK for C/C++

RocketMQ SDK 5.x is designed and built following principles of cloud-native. rocketmq-apis defines a new collection of APIs, which specify how clients talk to servers in a language agnostic way.

By embracing gRPC ecological system, efforts of developing a new SDK are roughly aligned for different languages. The semantics of each API are guaranteed to be consistent across languages.

Features

• Publish standard messages;
• Publish scheduled messages;
• Publish FIFO messages;
• Classic message listener style of message subscription;
• SimpleConsumer offers application developers maximum flexibility;
• Intelligent load-balancing among consumers of the same group;
• Integration of OpenTelemtry, providing industry-standard observability;