Google Git
Sign in
apache / rocketmq-client-go / HEAD
  1. ee5a175 fix PullThresholdForQueue and PullThresholdSizeForQueue update (#1140) by wenxuwan · 3 weeks ago master
  2. 0e19ee6 Send retry as a normal message when sendMessageBack fails (#1107) by Liu Shengzhong · 5 weeks ago
  3. f4875c1 Merge pull request #1125 from MaOreoreorui/master by tiger lee · 10 weeks ago
  4. 7a89bba fix: panic in SendResult.String (#1124) by maoruilei3120 · 5 months ago
  5. af567d2 feat: connection add debug log (#1118) by WeizhongTu · 5 months ago
  6. 5af5d6d fix: ignore name server connection read timeout log (#1117) by WeizhongTu · 5 months ago
  7. 3f9c59f fix: response future should close channel before callback (#1113) by WeizhongTu · 5 months ago
  8. 7ffb599 [ISSUE #1112] feat: optimize producer send async (#1111) by WeizhongTu · 5 months ago
  9. 7ae83c4 fix: fix producer send msg timeout option does not take effect (#1109) by WeizhongTu · 6 months ago
  10. c9e197c [ISSUE #950] support tls connection (#951) by yuz10 · 6 months ago
  11. 8e701a5 Merge pull request #1063 from nanfengonline/fixTypo by tiger lee · 7 months ago
  12. 49f0448 Merge pull request #1104 from 474903784/fix_send_async by tiger lee · 7 months ago
  13. a22cfcb [ISSUE #1102] fix send async err occur panic: runtime error: invalid memory address or nil pointer dereference by liuwenxing · 7 months ago
  14. 3493a47 feat: support consumer consume tps option (#1101) by WeizhongTu · 7 months ago
  15. da20ee7 [ISSUE #1076] fix: sort Topic routing information to ensure that order messages are sent normally by cserwen · 8 months ago
  16. 5eab91b fix: snapshot file will be overwritten and mixed if multiple consumers or producers use different name server domains (#1099) by WeizhongTu · 8 months ago
  17. 4de354a add lock to protect data race (#1088) by wenxuwan · 8 months ago
  18. 7eedaf9 fix: topic publshInfo and subscribeInfo not update (#1084) by redlsz · 10 months ago v2.1.2 v2.1.2.rc2
  19. e22605a run RebalanceImmediately with goroutine (#1081) by wenxuwan · 10 months ago
  20. 533de03 fix: select one message queue of different broker when retry to send (#1014) by cserwen · 11 months ago
  21. a15c777 [ISSUE #1056] fix: When the consumer and producer have the same topic, the consumer fails to update the topic. by lvxiao · 11 months ago
  22. 49eb1fc fix typo by nanfengonline · 12 months ago
  23. f7960e7 fix typo by nanfengonline · 12 months ago
  24. 2a8172b DomainWithUnit support existed query parameters (#1061) by WeizhongTu · 12 months ago
  25. 8c4e388 change ConsumeGoroutineNums max value allowed (#1049) by WeizhongTu · 1 year ago
  26. 1d86ea6 support RequestCode GET_CONSUMER_STATUS_FROM_CLIENT (#985) by Kay Du · 1 year ago
  27. 8ea107c [ISSUE #1018] Fix unintended shutdown of shared rmqClient by Gordon Wang · 1 year, 1 month ago
  28. 1c6598f fix wrong add for set when tags are set (#1001) by cserwen · 1 year, 1 month ago
  29. af75f77 empty subcribed topic is allowed to start (#969) by Kay Du · 1 year, 1 month ago
  30. ded5335 [ISSUE #1030] avoid to append unexpected separator to the last message key (#1031) by gaofeihang · 1 year, 1 month ago
  31. d5f5776 fix can't send batch message error (#1040) by tiger lee · 1 year, 1 month ago
  32. 63a5a1f [ISSUE #1034] fix: the message may be cleaned when the message has not been consumed by Humkum · 1 year, 1 month ago
  33. c77a95d fix: unsubscribed topic queues not dropped (#1025) by Gordon Wang · 1 year, 1 month ago
  34. 25003f6 Update README.md (#1026) by Qin · 1 year, 1 month ago v2.1.2.rc1
  35. 7f3ffe25c [ISSUE #989] consumer and producer client add unit support (WithUnitName) by WeizhongTu · 1 year, 1 month ago
  36. 7ae788d fix Panic when close traceDispatcher (#1027) by wenxuwan · 1 year, 1 month ago
  37. 6c77b67 Merge pull request #972 from BLAZZ/master by fuyou001 · 1 year, 2 months ago
  38. 3b8b238 Merge pull request #1015 from cserwen/orderly_consume_github by tiger lee · 1 year, 2 months ago
  39. 56d1a7d Merge pull request #1003 from cserwen/heartbeat_github by tiger lee · 1 year, 2 months ago
  40. 9bca88d fix: unlock all queues when consumer shutdown in orderly model by dengzhiwen1 · 1 year, 2 months ago
  41. ae93d2a Merge pull request #1000 from Slideee/20230213/rmq by tiger lee · 1 year, 2 months ago
  42. caca3c0 [ISSUE #999] add timeoutMillis param by yechun · 1 year, 3 months ago
  43. c133cca [ISSUE #999] use structs as result sets for admin method by yechun · 1 year, 3 months ago
  44. 62d4513 [ISSUE #999] fix npe by yechun · 1 year, 3 months ago
  45. 26142da fix: client version mismatch (#1009) by qshuai · 1 year, 3 months ago
  46. df5be5b fix: add log when send heartbeat failed by dengzhiwen1 · 1 year, 3 months ago
  47. c8d06a6 [ISSUE #996] invoke user callback and return error info when async process send resp error (#997) by wangfan · 1 year, 3 months ago
  48. daacb8e [ISSUE #999]support admin topicList and groupList method by yechun · 1 year, 3 months ago
  49. a2cf953 fix:logic error when reset retry message's origin topic (#971) by Humkum · 1 year, 3 months ago
  50. 757e639 Merge pull request #987 from humkum/reduce-log-level by cserwen · 1 year, 3 months ago
  51. cfb845b reduce the log level when fetch offset success and remove unnecessary mq by Hankunming · 1 year, 4 months ago
  52. 896a8a3 [ISSUE #975]when close consumer, return directly by wenxuwan · 1 year, 5 months ago
  53. 12740f0 change uuid to google/uuid by 邬奇辉 · 1 year, 5 months ago
  54. f56a2db fix: data race when update subversion for consumer (#962) by cserwen · 1 year, 5 months ago
  55. cad2f66 add api GetOffsetDiffMap (#965) by Kay Du · 1 year, 5 months ago
  56. 0742aac push consumer enable getting offset diff map (#964) by Kay Du · 1 year, 5 months ago
  57. 6bbfc3f [ISSUE #956]fix reset offset remove pq (#957) by 0daypwn · 1 year, 6 months ago
  58. 96f00c4 [ISSUE #953] fix limiter with goroutine cover (#952) by maqingxiang · 1 year, 6 months ago
  59. 8afd69f [ISSUE #927] fix processQueue remove offset (#928) by 0daypwn · 1 year, 7 months ago
  60. c197b50 [ISSUE #931] fix filter message (#932) by 0daypwn · 1 year, 7 months ago
  61. 5779439 [ISSUE #942] Fix response ResQueryNotFound typo (#948) by Jack Wong · 1 year, 7 months ago
  62. 620cf96 [ISSUE #942] fix some spell mistakes (#949) by weavernet · 1 year, 7 months ago
  63. ff80272 [ISSUE #942] correct name typo (#943) by 0daypwn · 1 year, 7 months ago
  64. 50596e6 Create .asf.yaml by yukon · 1 year, 7 months ago
  65. 43186ad [#888] incr instanceCount in once and fmt codes (#888) by Xuexue · 1 year, 7 months ago
  66. b3ede3a [ISSUE #935]fix consumer option validate (#936) by 0daypwn · 1 year, 7 months ago
  67. f3349bd [ISSUE #939]Pull or poll message support message trace (#940) by zhangjidi2016 · 1 year, 7 months ago
  68. a093bac [ISSUE #945]init crCh after topic with namespace to avoid consumption blocked. (#944) by Kay Du · 1 year, 7 months ago
  69. 8011561 [ISSUE #929] Correct struct comment (#930) by Oliver · 1 year, 7 months ago
  70. 92515f7 [ISSUE #926] don't share limit channel in pushConsumer (#923) by Xuexue · 1 year, 8 months ago
  71. 4c9c5db [ISSUE #922]close file after it was read in internal fiel utils. by 子非鱼 · 1 year, 8 months ago
  72. 0323905 update introduction.md (#913) by Oliver · 1 year, 8 months ago
  73. a343f1b fix consumer stopped consuming when panic in consumeListener (#910) by cserwen · 1 year, 9 months ago
  74. 3f06d9a when queue dropped,should'not consume the process queue.(#905) (#906) by Nick · 1 year, 9 months ago
  75. de2dc05 fix:when msgCh full,can't release the pq.mutex lock,removeMessage method will blocked. (#903) by Nick · 1 year, 9 months ago
  76. 398ae67 [ISSUE #907]remove useless stats log by Nick · 1 year, 9 months ago
  77. 2630383 [ISSUE #901]Close the traceDispatcher when producer or consumer is shutdown (#902) by zhangjidi2016 · 1 year, 9 months ago
  78. 39619b9 [ISSUE #899]Fix the groupName takes the namespace prefix (#900) by zhangjidi2016 · 1 year, 9 months ago
  79. c9ca891 [ISSUE #845] support standard json by yuz10 · 1 year, 9 months ago
  80. 2e1b335 (feat): add user defined topic dimension consumer limiter (#895) by Robin Han · 1 year, 9 months ago
  81. ced8ba7 fix consumer doesn't consume message because of blocked on Lock in some case (#898) by givemeafish · 1 year, 9 months ago
  82. fedf106 (feat): add filter hooks (#891) by Robin Han · 1 year, 9 months ago
  83. 1c75f23 Update readme file according to the new features in the latest release version. (#893) by dinglei · 1 year, 9 months ago
  84. bd3bd12 [ISSUE #862] Update client version in Readme file. by dinglei · 1 year, 9 months ago
  85. ae76839 feat: support lite pull consumer (#881) by Nick · 1 year, 9 months ago
  86. ffd7241 [feat] fix query not found (#886) by Xuexue · 1 year, 9 months ago
  87. e1ddb88 Add param which like consumeThreadMin of java sdk to control consumption rate (#883) by cserwen · 1 year, 9 months ago
  88. 43edd17 [ISSUE #884]fix goroutine leak (#885) by Nick · 1 year, 9 months ago
  89. 3ccfbff keep queryTopicRouteInfoFromServer timeout the same as Java (#880) by WeizhongTu · 1 year, 10 months ago
  90. 5aa04a2 clean expired message in CLUSTERING model for push_consumer (#879) by cserwen · 1 year, 10 months ago
  91. 6c2f270 [ISSUE #876] Safely checking context in trace producer. (#863) by Xuexue · 1 year, 10 months ago
  92. 0fb106c Update release date link in readme file. by dinglei · 1 year, 10 months ago
  93. 129701a Merge pull request #873 from ShannonDing/codecove_failed by Heng Du · 1 year, 10 months ago release-v2.1.1 v2.1.1 v2.1.1-rc3
  94. ee05725 fix code coverage shell error in travis ci yml. by ShannonDing · 1 year, 10 months ago
  95. f3d4f5d [ISSUE #870] add license header for some new files. (#871) by dinglei · 1 year, 10 months ago
  96. b6d6f07 [ISSUE #790] use uber atomic lib to avoid atomic value data race. (#866) by WJL3333 · 1 year, 10 months ago
  97. 595f2d9 Fix: api comments (#867) by Laurence · 1 year, 10 months ago
  98. 159ac27 update rlog to 1.9.0 to fix CVE-2022-29526 in (#868) by dinglei · 1 year, 10 months ago
  99. 9ce8e66 [ISSUE #728] client shutdown abnormally (#729) by zhangyang · 1 year, 10 months ago
  100. 9a16e86 avoid sendmessage back with origin message body in request. (#865) by WJL3333 · 1 year, 10 months ago