Releases: apache/rocketmq-clients
Java-5.0.0
- adapt with rocketmq-apis
- add producer/push consumer/simple consumer
- support NORMAL/FIFO/DELAY/TRANSACTION message
- OpenTelemetry metrics support
CPP-5.0.0-rc1
- Publish standard messages;
- Publish FIFO messages;
- Publish timed messages;
- Publish transactional messages;
- Message-listener-based PushConsumer for concurrent use case;
- Message-listener-based PushConsumer for FIFO groups/messages;
- SimpleConsumer, providing maximum flexibility of message consumption
based on raw API; - Custom retry policy when throttled;
- Modern observability complying with OpenCensus/OpenTelemetry;
CPP-5.0.0-preview
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;
CPP-5.0.0-beta
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;