Google Git Google Git
Sign in
apache/rocketmq-clients/HEAD
  1. f9cb7f4 fix(rust): relax dependency upper-bound pins so downstream can use newer versions (#1468) by Lei Zhiyuan · 2 days ago master
  2. e90ece7 fix(ci): repair the Rust Coverage workflow startup failure (#1444) by lizhimins · 4 days ago
  3. 50a5df5 [ISSUE #1412] [CI] Restore rust-build as a gating check for build-result (#1443) by lizhimins · 5 days ago
  4. 3549cb5 [ISSUE #1440] [Rust] Select readable master queues for SimpleConsumer and start at a random index (#1441) by Lei Zhiyuan · 5 days ago
  5. 086c38a [ISSUE #1438] [Rust] Return an empty receipt handle instead of panicking when a MessageView has none (#1439) by Lei Zhiyuan · 5 days ago
  6. c25b9a2 [ISSUE #1432] [Rust] Roll back a failed start and check state in SimpleConsumer operations (#1433) by Lei Zhiyuan · 5 days ago
  7. 2f4ae8c [ISSUE #1430] [Rust] Refresh MessageView receipt handle after change_invisible_duration (#1431) by Lei Zhiyuan · 5 days ago
  8. 222e078 [ISSUE #1426] [Rust] Validate SimpleConsumer receive arguments instead of panicking (#1427) by Lei Zhiyuan · 5 days ago
  9. f9869e8 [ISSUE #1434] [Rust] Set suspend when LiteSimpleConsumer changes the invisible duration of a lite message (#1435) by Lei Zhiyuan · 5 days ago
  10. 9e74b6b [ISSUE #1408] [Rust] Apply server lite settings in LitePushConsumer (#1409) by Lei Zhiyuan · 5 days ago
  11. e0cd6e0 [ISSUE #1422] [Rust] Stop receiving once shutdown starts and shut queue actors down concurrently (#1423) by Lei Zhiyuan · 5 days ago
  12. abd0b90 [ISSUE #1424] [Rust] Apply server long polling timeout to the receive deadline in PushConsumer (#1425) by Lei Zhiyuan · 5 days ago
  13. d7408c7 [rust] Add LiteSimpleConsumer with tests and example (#1381) by zhaohai · 5 days ago
  14. d0f3cd1 Fix/rust telemetry session defects (#1404) by zhaohai · 6 days ago
  15. 9f77cf1 [ISSUE #1428] [Rust] Decompress received message body and verify its digest (#1429) by Lei Zhiyuan · 6 days ago
  16. 6285089 [ISSUE #1413] [Rust] Increase delivery attempt on FIFO local retry (#1414) by Lei Zhiyuan · 6 days ago
  17. d8637d2 [ISSUE #1410] [Rust] Treat a panic in the PushConsumer listener as consume failure (#1411) by Lei Zhiyuan · 6 days ago
  18. c4c063f [ISSUE #1415] [Rust] Reject lite batch and check send receipt count (#1416) by Lei Zhiyuan · 6 days ago
  19. 8a686b5 [ISSUE #1419] [Rust] Strip http:// and https:// prefix from access url (#1421) by Lei Zhiyuan · 6 days ago
  20. 18468ee [ISSUE #1418] [Rust] Reject blank lite topic in MessageBuilder (#1420) by Lei Zhiyuan · 6 days ago
  21. 3a47e1d [ISSUE #1406] [Rust] Take PushConsumer filter expression from the subscription (#1407) by Lei Zhiyuan · 6 days ago
  22. 7b0e26c [ISSUE #1412] [CI] Stop gating build-result on the Rust build (#1442) by lizhimins · 6 days ago
  23. f9829e5 fix(nodejs): create the first-settings promise before any await in startup (#1405) by zhaohai · 7 days ago
  24. a3d1de8 enhancement(nodejs): bump version to 1.1.0 (#1398) by Quan · 2 weeks ago
  25. 6b0bcc4 [Node.js] Fix ESLint errors in src and test so the lint gate passes (#1396) by Quan · 2 weeks ago
  26. fa490c2 Feat/nodejs message interceptor hooks (#1384) by zhaohai · 3 weeks ago
  27. 6c96a83 feat(nodejs): add consumer-side rate limiting via semaphore backpressure (#1386) by zhaohai · 3 weeks ago
  28. 8fd7226 Feat/nodejs metrics export (#1387) by zhaohai · 3 weeks ago
  29. 4123af4 fix(nodejs): correct message-group routing and consumption lifecycle guards (#1388) by zhaohai · 3 weeks ago
  30. 13b9299 Feat/nodejs ip name resolver (#1385) by zhaohai · 3 weeks ago
  31. cd738fa fix(nodejs): transport layer self-healing and logger close deferral (#1375) by zhaohai · 5 weeks ago
  32. 2a554b9 fix(nodejs): fail fast on NotFoundException during startup route fetch (#1374) by zhaohai · 5 weeks ago
  33. 51561a1 enhancement(nodejs): isolate gRPC connections between client instances (#1383) by Quan · 5 weeks ago
  34. 3357f9c fix(nodejs): align retry units, endpoints parsing (#1373) by zhaohai · 5 weeks ago
  35. cf0893a feat(nodejs): implement LiteSimpleConsumer (#1379) by zhaohai · 6 weeks ago
  36. 981a507 fix(golang): close the receive hook when long polling finds no message (#1378) by guyinyou · 6 weeks ago
  37. 2bbe25b [csharp] Add LiteSimpleConsumer with tests and example (#1380) by zhaohai · 6 weeks ago
  38. 2513a7b [Go] Align half-open gRPC recovery with Java (#1377) by guyinyou · 6 weeks ago
  39. fc4b90b [C#] Align half-open gRPC recovery with Java (#1371) by guyinyou · 6 weeks ago
  40. fc088d4 test(nodejs): use a fixed consumer group in the simple consumer integration test (#1376) by zhaohai · 6 weeks ago
  41. 07697f7 Update version to 5.1.2, Support LiteSimpleConsumer and fix some bugs for RocketMQ python SDK. (#1372) by zhouli11 · 6 weeks ago
  42. 8b3bb96 enhancement(nodejs): bump version to 1.0.8 (#1364) by Quan · 7 weeks ago
  43. 17677fe [ISSUE #1362] [C#] Fix typo in csharp/LICENSE: "(properties)" -> "(i)" (#1363) by lizhimins · 8 weeks ago
  44. 0ffab35 fix(nodejs): drain inflight receives and cached messages on PushConsumer shutdown (#1353) by Quan · 8 weeks ago
  45. 666dfbc fix(nodejs): floor seconds when constructing protobuf Duration (#1352) by Quan · 9 weeks ago
  46. 6e2185b [maven-release-plugin] prepare release java-5.2.2 (#1349) by lizhimins · 9 weeks ago java-5.2.2
  47. da8271b [ISSUE #1334] [C++] Fix PushConsumer teardown crash and add explicit shutdown() (#1336) by lizhimins · 2 months ago cpp-5.1.1
  48. ccc0d4f [ISSUE #1335] [C++] Bound the synchronous producer paths with the request timeout (#1337) by lizhimins · 2 months ago
  49. 3a8ec61 [Go] Re-check isCacheFull() on backoff expiry to avoid cache overflow (#1328) by Liu Shengzhong · 3 months ago
  50. f790a48 [Go] Fix round-robin load balancer always selecting the same queue (#1324) by guyinyou · 3 months ago
  51. d463e64 [ISSUE# 1321] [Java] Preserve attempt ID until messages are received (#1322) by qianye · 3 months ago
  52. 9abb7f3 [ISSUE #1318] [Java] Support opt-in virtual threads (#1319) by qianye · 3 months ago
  53. 9fe1449 [ISSUE #1309] [Java] Improve gRPC transport resilience (#1310) by qianye · 3 months ago
  54. 5447111 feature(golang): support LiteSimpleConsumer (#1314) by Quan · 3 months ago
  55. 5939e37 [Go] Fix resource leaks on client close (#1305) by guyinyou · 3 months ago
  56. 3180b68 fix: add CODECOV_ACTION_KEY token and upgrade actions in golang coverage workflow (#1302) by lizhimins · 4 months ago
  57. 47c2a64 [C++] Fix thread safety bugs and add comprehensive unit tests (#1301) by lizhimins · 4 months ago cpp-5.1.0
  58. 41b65fa [C++] Update public API and simplify client lifecycle state machine (#1300) by lizhimins · 4 months ago
  59. 9c9ce3c [C++] Add CMake install/uninstall support and enable tests in CI (#1297) by lizhimins · 4 months ago
  60. 42a965c feat(consumer): implement LitePushConsumer with FIFO and standard consume services (#1294) by Drizzle · 4 months ago
  61. 315f98e [Java] Record consumegroup when consumeMessage (#1290) by ymwneu · 4 months ago
  62. d4de689 [Go] Fix LitePushConsumer.WrapReceiveMessageRequest using wrong AutoRenew value (#1291) by Quan · 4 months ago
  63. f038a53 [Go] Support offset option for lite topic subscriptions (#1285) by Yim · 4 months ago
  64. 3d8e99f [Java] Support client properties for observability and management (#1237) by JYZ · 4 months ago
  65. eb6fe0b [Java] Build rocketmq-proto from submodule instead of depending on Maven Central (#1287) by lizhimins · 4 months ago
  66. 37cbdf6 Prepare C# SDK 5.2.1 release (#1283) by rongtong · 4 months ago csharp-5.2.1
  67. 5ef95b8 Prepare Go SDK 5.1.4 release (#1282) by rongtong · 4 months ago golang/v5.1.4
  68. 471044f [maven-release-plugin] prepare release java-5.2.1 (#1278) by lizhimins · 4 months ago java-5.2.1
  69. 7448aa1 [Go] Fix data race in receiveMessage for push and simple consumers (#1275) by guyinyou · 5 months ago
  70. 882c5be [Golang] fix(process_queue.go): correct log format verbs in receiveMessage error logging (#1253) by ZM · 5 months ago
  71. 47d0a47 Add lite consumer sub all liteTopic (#1274) by Drizzle · 5 months ago
  72. f17e6df [Go] Fix Commit/RollBack always returning nil in transaction (#1271) by guyinyou · 5 months ago
  73. 9713aaf [Go] Fix double execution of telemetry command during recovery (#1270) by guyinyou · 5 months ago
  74. ec29fca [Go] Fix inverted hook status in Ack/DLQ methods (#1269) by guyinyou · 5 months ago
  75. c46bc3f [C#] Fix SetBody validation logic to correctly reject null and empty body (#1268) by guyinyou · 5 months ago
  76. 061dd50 [C#] Fix missing return after InvalidReceiptHandle in AckMessage and ChangeInvisibleDuration (#1267) by guyinyou · 5 months ago
  77. e9521d5 fix(golang): add missing return in SendAsync when producer is off (#1264) by guyinyou · 5 months ago
  78. bf4462c [Go] Fix missing return after retry scheduling in process_queue (#1265) by guyinyou · 5 months ago
  79. 323fe20 [Go] Fix forwardToDeadLetterQueueLater incorrectly calling ackMessage instead of forwardToDeadLetterQueue (#1266) by guyinyou · 5 months ago
  80. 913d5de fix(ci): join git diff output to single line for GITHUB_OUTPUT (#1263) by lizhimins · 5 months ago
  81. 189d2d5 fix(ci): fix paths-filter shallow clone failure and cpp coverage token (#1262) by lizhimins · 5 months ago
  82. 446f3be [C#] Add .NET 10 support and fix build warnings (#1260) by zynetYu · 5 months ago
  83. 039ee85 [C++] Upgrade Bazel 5.2.0 to 6.6.0, add Bazel CI, migrate coverage to CMake (#1261) by lizhimins · 5 months ago
  84. 77fdb6f Bump protobufjs from 7.5.6 to 7.6.1 in /nodejs (#1254) by dependabot[bot] · 5 months ago
  85. df8759f [C++] Fix critical correctness, thread safety, and memory management bugs (#1259) by lizhimins · 5 months ago
  86. f1df051 [C++] Improve CMake build system, fix warnings, and restore cross-platform CI (#1257) by lizhimins · 5 months ago
  87. d35c2c2 fix(csharp): correct inverted condition in GetMacAddress to prevent ArgumentOutOfRangeException on macOS arm64 (#1255) by guyinyou · 5 months ago
  88. e9f2ae7 feat(LitePushConsumer): support concurrent consumption for LitePushConsumer (#1248) by Quan · 5 months ago
  89. 66b340d [C++] Support priority message (#1241) by zhaohai · 5 months ago
  90. 730a172 optimize the nodejs client (#1247) by Drizzle · 6 months ago
  91. ca77ac9 fix(ClientImpl.java): broadcast SyncLiteSubscriptionRequest to all route endpoints (#1245) by Quan · 6 months ago
  92. e5f73f5 Rust support FIFO consume accelerator for push consumer, recalling timed/delay messages for Producer and Priority Message.It also supports the Lite Push Consumer. (#1227) by zhaohai · 6 months ago
  93. 9d026ed fix(client.go): nil pointer exception during close (#1243) by Quan · 6 months ago
  94. 6361fe3 refactor(log.go): unify log configuration default value management (#1239) by Quan · 6 months ago
  95. a5b541c fix(log.go): adjust log file size unit and enable local time (#1238) by Quan · 6 months ago
  96. 2ac0bdd The C# client supports producers in recalling timed and delayed messages, as well as sending priority messages. It also supports the Lite Push Consumer. (#1229) by zhaohai · 6 months ago
  97. 73c415b fix(client.go): handle sync settings error during startup (#1235) by Quan · 6 months ago
  98. 9cde194 Go client supports Producer with recalling timed/delay messages and Priority Message. (#1231) by zhaohai · 6 months ago
  99. d71c6c5 Fix priority issue.Supports lightweight messaging. (#1215) by zhaohai · 6 months ago
  100. e05d5a9 [Golang] fix(client.go): fix bug where NotifyClientTermination was never called (#1221) by Quan · 7 months ago