Google Git
Sign in
apache/rocketmq-clients/HEAD
  1. e9f2ae7 feat(LitePushConsumer): support concurrent consumption for LitePushConsumer (#1248) by Quan · 3 days ago master
  2. 66b340d [C++] Support priority message (#1241) by zhaohai · 5 days ago
  3. 730a172 optimize the nodejs client (#1247) by Drizzle · 10 days ago
  4. ca77ac9 fix(ClientImpl.java): broadcast SyncLiteSubscriptionRequest to all route endpoints (#1245) by Quan · 11 days ago
  5. 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 · 11 days ago
  6. 9d026ed fix(client.go): nil pointer exception during close (#1243) by Quan · 2 weeks ago
  7. 6361fe3 refactor(log.go): unify log configuration default value management (#1239) by Quan · 3 weeks ago
  8. a5b541c fix(log.go): adjust log file size unit and enable local time (#1238) by Quan · 3 weeks ago
  9. 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 · 3 weeks ago
  10. 73c415b fix(client.go): handle sync settings error during startup (#1235) by Quan · 4 weeks ago
  11. 9cde194 Go client supports Producer with recalling timed/delay messages and Priority Message. (#1231) by zhaohai · 4 weeks ago
  12. d71c6c5 Fix priority issue.Supports lightweight messaging. (#1215) by zhaohai · 5 weeks ago
  13. e05d5a9 [Golang] fix(client.go): fix bug where NotifyClientTermination was never called (#1221) by Quan · 6 weeks ago
  14. 3cc5cdf fix(log.go): improve log directory retrieval logic (#1220) by Quan · 6 weeks ago
  15. d581a03 [Golang] fix(conn): add max receive message size configuration option (#1219) by Quan · 6 weeks ago
  16. 1f09375 feat(csharp): parallel FIFO consume by message group (#1218) by guyinyou · 6 weeks ago
  17. 17ab1b4 feat(csharp): graceful PushConsumer shutdown aligned with Go client (#1217) by guyinyou · 7 weeks ago
  18. 505e1fd feat(LitePushConsumer): enable Lite Push Consumer to suspend consumption (#1206) by Quan · 7 weeks ago
  19. d483551 The Node.js SDK supports the following features: Producing scheduled and delayed messages FIFO message listening with push consumer FIFO consumption acceleration with push consumer Priority messaging (#1211) by zhaohai · 8 weeks ago
  20. e97a2cd [ISSUE #1196] [Java] Increase max cached message count limit for PushConsumer (#1214) by lizhimins · 8 weeks ago
  21. a96e590 refactor(lite_push_consumer): enable Lite Push Consumer to suspend consumption (#1203) by Quan · 9 weeks ago
  22. 5b54c56 nodeJs demo (#975) by zhaohai · 10 weeks ago
  23. 5ec167b Node js push consumer (#1201) by zhaohai · 10 weeks ago
  24. 80a5bbf [ISSUE #1187] [Java] Implementation of lite simple consumer (#1188) by Quan · 10 weeks ago
  25. a5b9584 chore(.licenserc.yaml): add golang/*_mock.go to ignore list (#1193) by Quan · 4 months ago
  26. 8d5d765 Release python sdk 5.1.1 (#1192) by zhouli11 · 4 months ago
  27. 2a9fb85 [maven-release-plugin] prepare for next development iteration (#1186) by lizhimins · 4 months ago
  28. f13d28e [maven-release-plugin] prepare release java-5.2.0 (#1184) by lizhimins · 4 months ago
  29. 652a140 [Java] Fix opentelemetry-instrumentation-compatibility CI (#1185) by qianye · 4 months ago
  30. c159a67 [ISSUE #1150] [Java] Support OffsetOption for subscribeLite (#1151) by Quan · 4 months ago
  31. 3c6f6fa [ISSUE #1161] [Golang] Client support ipv6 hostip:port (#1162) by SHI · 4 months ago
  32. 1139cfb [ISSUE #1174] [C++] Optimize the logic for generating the uniqueId of messages (#1175) by lizhimins · 4 months ago
  33. 601aee5 refactor(lite_push_consumer): use `sync.Map` to replace regular map and fix related method calls (#1171) by Quan · 4 months ago
  34. 399a39e [ISSUE #1107] [Golang] LiteTopic support for "RIP‐83 Lite Topic" (#1110) by cvictory · 5 months ago
  35. 5472484 [Python] Fix PushConsumer not receiving messages (#1169) by Marandi269 · 5 months ago
  36. ab66ab6 Add example of sending lite_topic in python sdk. (#1170) by zhouli11 · 5 months ago
  37. 0b838e7 Release Python SDK 5.1.0 (#1167) by zhouli11 · 5 months ago
  38. 8903b2f [ISSUE #1152] [RIP-80] [Java] Implementation of Priority Message (#1153) by imzs · 5 months ago
  39. 692dd72 [ISSUE #1163] Correct document spelling errors (#1164) by yx9o · 5 months ago
  40. d396227 [ISSUE #1159] [C++] Use Pass-by-Value instead of Pass-by-Reference for attemptId in PushConsumer (#1160) by lizhimins · 5 months ago cpp-5.0.4
  41. e7097ae [ISSUE #1156] [C++] SimpleConsumer support subscription expression (#1158) by lizhimins · 5 months ago
  42. a9bb6ff [ISSUE #1035] [C++] Supports configuring the number of client threads (#1155) by lizhimins · 5 months ago
  43. 576e61b golang: Added rate limiting for SimpleConsumer's Receive requests by clientID dimension (#1141) by guyinyou · 5 months ago
  44. fd58dab [ISSUE #1145] Make ClientServiceProvider.loadService Thread-Safe with Lazy Initialization (#1146) by qianye · 6 months ago
  45. c47025c Release python SDK 5.0.9 (#1144) by zhouli11 · 6 months ago
  46. 6a51929 Release Python SDK, version: 5.0.8 (#1142) by zhouli11 · 6 months ago
  47. ac19e79 [ISSUE #1133] The java client adds the maxStartupAttempts parameter to configure the retry times at startup (#1134) by qianye · 6 months ago
  48. 90d9f15 Optimize ProducerTransactionMessageExample.java demo by qianye · 7 months ago
  49. 80962ad Support fifo parallel consume in go pushconsumer (#1122) by guyinyou · 7 months ago
  50. a11dbf8 fix resource (#1119) by zhaohai · 7 months ago
  51. 2406234 [maven-release-plugin] prepare for next development iteration (#1115) by lizhimins · 7 months ago
  52. c996ee9 [maven-release-plugin] prepare release rocketmq-client-java-parent-5.1.0 (#1114) by lizhimins · 7 months ago java-5.1.0
  53. ef21697 [ISSUE #1107] [Java] LiteTopic support for "RIP‐83 Lite Topic" (#1108) by Quan · 7 months ago
  54. 6cc3717 [ISSUE #1098] [Golang] Ensure proper closure of done channel on receive message error (#1099) by Lei Zhiyuan · 9 months ago
  55. 306b197 [ISSUE #1075] [Golang] Support ReconnectEndpointsCommand (#1076) by takagi · 9 months ago golang/v5.1.3
  56. 3c37fbe [ISSUE #1070] [Golang] Add SSL configuration when starting the client (#1072) by takagi · 9 months ago
  57. 0c837c6 [ISSUE #1055] [Golang] Enhance grpc failover resilience (#1069) by takagi · 9 months ago
  58. e976290 [ISSUE #1083] [Golang] Triggering the judgment whether it is empty during task execution (#1084) by takagi · 9 months ago
  59. 7389a30 [ISSUE #1057] [Java] Enhance MessageImpl to allow subclasses to access properties (#1058) by bcaw-ofeer · 9 months ago
  60. 6bbd251 [ISSUE #1060] [Java] Enhance the logic of MessageInterceptor (#1061) by bcaw-ofeer · 9 months ago
  61. ea99f9e [ISSUE #1081] [Java] Fix missing protos (#1091) by lizhimins · 9 months ago
  62. 8905f83 [ISSUE #1081] [Java] Support message filtering in interceptors with proper acknowledgment handling (#1082) by bcaw-ofeer · 9 months ago
  63. 444c764 [Rust] Fix Github Rust Workflow (#1090) by EnableAsync · 9 months ago
  64. eec7790 [Rust] Fix Github Rust Workflow (#1089) by EnableAsync · 9 months ago
  65. 3dc40e9 [ISSUE #1051] Upgrade slf4j version to match current logback version (#1052) by ymwneu · 10 months ago
  66. fee5a00 [ISSUE #1043] [Rust] Improve message status and timestamp handling (#1044) by Adam Basfop Cavendish · 10 months ago
  67. 759aa42 [ISSUE #1040] [Rust] Migrate from slog to tracing logging framework by Adam Basfop Cavendish · 10 months ago
  68. dde1c72 [ISSUE #1037] Increase dependency version of opentelemetry library (#1038) by takagi · 10 months ago
  69. 9adc3ce [ISSUE #1035] [C++] Support continuous visibility timeout adjustment for SimpleConsumer (#1039) by lizhimins · 11 months ago cpp-5.0.3
  70. a7d43d1 [ISSUE #9470] [Java] Support ReconnectEndpointsCommand (#1018) by ymwneu · 11 months ago
  71. 008b455 [ISSUE #903] [Rust] Fix sync settings show an error after the connection is closed by the server side (#1025) by EnableAsync · 11 months ago
  72. 40f5d5e golang: compatible with some abnormal scenarios, such as flowlimit by guyinyou · 11 months ago
  73. 2306251 golang: when pushconsumer is shutdown, wait for messages that are already ready to be consumed (#1030) by guyinyou · 11 months ago
  74. 9a97773 golang: remove debug log (#1024) by guyinyou · 11 months ago
  75. dd8e60f golang: some optimizations regarding transaction messages and pushconsumer (#1021) by guyinyou · 11 months ago
  76. 1381f0a golang: add SetRequestTimeout implements producer/simpleConsumer/pushConsumer (#1016) by guyinyou · 12 months ago
  77. 7da326f [ISSUE #811] [Golang] should not copy sync.Map in loadBalancer (#810) by Vincent Lee · 12 months ago
  78. 2843ef5 [ISSUE #984] [C++] Support fifo parallel consume in C++ PushConsumer (#1009) by lizhimins · 12 months ago
  79. 48cf928 [ISSUE #872] [Java] feat: should add default keepalive for grpc channel (#870) by Vincent Lee · 12 months ago
  80. adb51ef [maven-release-plugin] prepare for next development iteration (#1007) by lizhimins · 12 months ago java-5.0.8
  81. eed120f [maven-release-plugin] prepare release rocketmq-client-java-parent-5.0.8 (#1006) by lizhimins · 12 months ago
  82. 093d793 Python 5.0.6 (#1004) by zhouli11 · 12 months ago
  83. d355724 Golang: add push consumer (#990) by guyinyou · 12 months ago
  84. 20757cc [ISSUE #816] Fix ack fail when Java Pushconsumer shutdown (#992) by qianye · 1 year ago
  85. c246dff [ISSUE #1001] C++ client should block on build when sync settings failed (#1002) by lizhimins · 1 year ago
  86. 4afe70e [ISSUE #984] Support fifo parallel consume in java pushconsumer (#985) by qianye · 1 year, 1 month ago
  87. 14e9d55 Use script to check changed files instead for dorny/paths-filter@v2 in action workflows. (#994) by Jixiang Jin · 1 year, 1 month ago
  88. b6fc23b Use script to check changed files instead for dorny/paths-filter@v2 in action workflows (#993) by Jixiang Jin · 1 year, 1 month ago
  89. 109dbc4 5.0.5 (#974) by zhouli11 · 1 year, 2 months ago
  90. 6eba103 adapt to localService (#973) by zhouli11 · 1 year, 2 months ago
  91. b727270 [ISSUE #969] C++ client support attemptId in PushConsumer (#970) by lizhimins · 1 year, 2 months ago
  92. bd1e7ab [ISSUE #967] C++ client support namespace, empty body check and recall message (#968) by lizhimins · 1 year, 2 months ago golang/v5.1.2
  93. c873eda [ISSUE #954] Add ZLib compression method in C# client (#955) by Jack Tsai · 1 year, 2 months ago
  94. d6a8de5 golang: Remove support for lz4 and zstd compression algorithms (#963) by guyinyou · 1 year, 2 months ago
  95. 784cd7c [ISSUE #959] Automatically select the appropriate decompression algorithm according to magic code (#960) by qianye · 1 year, 2 months ago
  96. 765a1cb Change lan to http in nodejs client (#962) by Drizzle · 1 year, 2 months ago
  97. 811e70b golang: support LZ4 and ZSTD compression algorithm (#958) by guyinyou · 1 year, 3 months ago
  98. 322e9a2 golang: support zlib decode (#957) by guyinyou · 1 year, 3 months ago
  99. f3c288e 5.0.4 (#950) transaction_check max workers by zhouli11 · 1 year, 3 months ago
  100. f117e73 [ISSUE #935] C++ simple consumer should remove destructor (#938) by lizhimins · 1 year, 3 months ago cpp-5.0.2