Google Git Google Git
Sign in
apache/rocketmq-client-go/HEAD
  1. 58d47b4 fix: initialize queue flow control before dispatching pulls (#1245) by wenxuwan · 12 hours ago master
  2. 461524a fix: Fix resource leaks and shutdown handling in shared clients (#1244) by wenxuwan · 13 days ago
  3. fa64715 fix: Fix shared trace dispatcher lifecycle and discovery (#1243) by wenxuwan · 2 weeks ago
  4. 99c4336 feat: support multi unit in trace config (#1233) by AnnaYue · 9 months ago
  5. 2173d07 fix(producer): prevent panic when TraceDispatcher is a typed nil (#1232) by JasonZhu · 10 months ago
  6. 83df64e fix decode CheckTransactionStateRequestHeader (#1225) by wsy6543 · 12 months ago
  7. f2fb16d unmarshalMsgID support ipv6 (#1203) by SHI · 12 months ago
  8. 3010ce9 feat: Add pause initialization to default PullConsumer to prevent panic (#1226) by wenxuwan · 12 months ago
  9. f1792b8 Update NOTICE by dinglei · 1 year, 1 month ago
  10. d857a13 feat: Fix concurrent subscriptions (#1222) by wenxuwan · 1 year, 1 month ago
  11. ab6584b [ISSUE #1205]Exposing cluster from admin (#1221) by takagi · 1 year, 1 month ago
  12. f44bcb8 feat: fix push consumer pause data race (#1219) by WeizhongTu · 1 year, 2 months ago
  13. b4b4df3 feat: fix push consumer pause data race (#1217) by WeizhongTu · 1 year, 2 months ago
  14. 33fe267 fix to#1207 (#1214) by fuyou001 · 1 year, 2 months ago
  15. 7d452fc fix trace messge batch more than batchSize (#1201) by wsy6543 · 1 year, 2 months ago
  16. 238fb46 fix OrderTopicConf (#1187) by wsy6543 · 1 year, 2 months ago
  17. 67ec50b Update README.md by dinglei · 1 year, 6 months ago
  18. 9b8bb01 [ISSUE #1194] check trace topic message queues length before queue-select to avoid divided-by-zero panic (#1195) by muyun.cyt · 1 year, 6 months ago
  19. bd8861c fix bug:seek offset won't work due to wrong map key type (#1184) by muyun.cyt · 1 year, 10 months ago
  20. abae4a0 make default panic handler could be customized (#1182) by WeizhongTu · 1 year, 11 months ago
  21. dd3dbcc [ISSUE #1178] feat:pull consumer support Assign subscription type by muyun.cyt · 1 year, 11 months ago
  22. 8a0459a Add stack info when consuming fail (#1164) by tiger lee · 1 year, 11 months ago
  23. 3538144 fix:callback function execution start context being canceled (#1175) by EthanLeo · 2 years ago
  24. ac4e3d6 fix: withRecover cannot recover panic (#1169) by EthanLeo · 2 years ago
  25. 9462ea8 [ISSUE #1136] should also set Credentials for nameserver in admin and pull consumer (#1137) by Vincent Lee · 2 years, 1 month ago
  26. 3e6b910 fix typo: PullConsumer -> PushConsumer in Introduction.md (#1166) by Yixia · 2 years, 1 month ago
  27. 0e45179 fix: fix slice init length (#1171) by cui fliter · 2 years, 1 month ago
  28. 7789818 feat: check domain empty string (#1130) by WeizhongTu · 2 years, 2 months ago
  29. 447cf73 [ISSUE #166] fix concurrency for message property string (#1141) by Vincent Lee · 2 years, 2 months ago
  30. fe4b42e fix get push consumer consumer rt (#1148) by SHI · 2 years, 2 months ago
  31. 98ee94d [ISSUE #1160] add brokerName in request protocol (#1161) by yuz10 · 2 years, 2 months ago
  32. 8cfa33a [ISSUE #1139] should use BrokerName for send back since the StoreHost in msg may not reachable in cloud env (#1138) by Vincent Lee · 2 years, 2 months ago
  33. 0422997 [ISSUE #1152] producer support message delay any time (#1158) by comman · 2 years, 2 months ago
  34. 9694e1c Update NOTICE by dinglei · 2 years, 5 months ago
  35. ee5a175 fix PullThresholdForQueue and PullThresholdSizeForQueue update (#1140) by wenxuwan · 2 years, 6 months ago
  36. 0e19ee6 Send retry as a normal message when sendMessageBack fails (#1107) by Liu Shengzhong · 2 years, 6 months ago
  37. f4875c1 Merge pull request #1125 from MaOreoreorui/master by tiger lee · 2 years, 8 months ago
  38. 7a89bba fix: panic in SendResult.String (#1124) by maoruilei3120 · 2 years, 10 months ago
  39. af567d2 feat: connection add debug log (#1118) by WeizhongTu · 2 years, 11 months ago
  40. 5af5d6d fix: ignore name server connection read timeout log (#1117) by WeizhongTu · 2 years, 11 months ago
  41. 3f9c59f fix: response future should close channel before callback (#1113) by WeizhongTu · 2 years, 11 months ago
  42. 7ffb599 [ISSUE #1112] feat: optimize producer send async (#1111) by WeizhongTu · 2 years, 11 months ago
  43. 7ae83c4 fix: fix producer send msg timeout option does not take effect (#1109) by WeizhongTu · 2 years, 11 months ago
  44. c9e197c [ISSUE #950] support tls connection (#951) by yuz10 · 3 years ago
  45. 8e701a5 Merge pull request #1063 from nanfengonline/fixTypo by tiger lee · 3 years ago
  46. 49f0448 Merge pull request #1104 from 474903784/fix_send_async by tiger lee · 3 years ago
  47. a22cfcb [ISSUE #1102] fix send async err occur panic: runtime error: invalid memory address or nil pointer dereference by liuwenxing · 3 years ago
  48. 3493a47 feat: support consumer consume tps option (#1101) by WeizhongTu · 3 years ago
  49. da20ee7 [ISSUE #1076] fix: sort Topic routing information to ensure that order messages are sent normally by cserwen · 3 years, 1 month ago
  50. 5eab91b fix: snapshot file will be overwritten and mixed if multiple consumers or producers use different name server domains (#1099) by WeizhongTu · 3 years, 1 month ago
  51. 4de354a add lock to protect data race (#1088) by wenxuwan · 3 years, 2 months ago
  52. 7eedaf9 fix: topic publshInfo and subscribeInfo not update (#1084) by redlsz · 3 years, 3 months ago v2.1.2 v2.1.2.rc2
  53. e22605a run RebalanceImmediately with goroutine (#1081) by wenxuwan · 3 years, 3 months ago
  54. 533de03 fix: select one message queue of different broker when retry to send (#1014) by cserwen · 3 years, 4 months ago
  55. a15c777 [ISSUE #1056] fix: When the consumer and producer have the same topic, the consumer fails to update the topic. by lvxiao · 3 years, 4 months ago
  56. 49eb1fc fix typo by nanfengonline · 3 years, 5 months ago
  57. f7960e7 fix typo by nanfengonline · 3 years, 5 months ago
  58. 2a8172b DomainWithUnit support existed query parameters (#1061) by WeizhongTu · 3 years, 5 months ago
  59. 8c4e388 change ConsumeGoroutineNums max value allowed (#1049) by WeizhongTu · 3 years, 6 months ago
  60. 1d86ea6 support RequestCode GET_CONSUMER_STATUS_FROM_CLIENT (#985) by Kay Du · 3 years, 6 months ago
  61. 8ea107c [ISSUE #1018] Fix unintended shutdown of shared rmqClient by Gordon Wang · 3 years, 6 months ago
  62. 1c6598f fix wrong add for set when tags are set (#1001) by cserwen · 3 years, 6 months ago
  63. af75f77 empty subcribed topic is allowed to start (#969) by Kay Du · 3 years, 6 months ago
  64. ded5335 [ISSUE #1030] avoid to append unexpected separator to the last message key (#1031) by gaofeihang · 3 years, 6 months ago
  65. d5f5776 fix can't send batch message error (#1040) by tiger lee · 3 years, 6 months ago
  66. 63a5a1f [ISSUE #1034] fix: the message may be cleaned when the message has not been consumed by Humkum · 3 years, 6 months ago
  67. c77a95d fix: unsubscribed topic queues not dropped (#1025) by Gordon Wang · 3 years, 6 months ago
  68. 25003f6 Update README.md (#1026) by Qin · 3 years, 6 months ago v2.1.2.rc1
  69. 7f3ffe25c [ISSUE #989] consumer and producer client add unit support (WithUnitName) by WeizhongTu · 3 years, 7 months ago
  70. 7ae788d fix Panic when close traceDispatcher (#1027) by wenxuwan · 3 years, 7 months ago
  71. 6c77b67 Merge pull request #972 from BLAZZ/master by fuyou001 · 3 years, 7 months ago
  72. 3b8b238 Merge pull request #1015 from cserwen/orderly_consume_github by tiger lee · 3 years, 7 months ago
  73. 56d1a7d Merge pull request #1003 from cserwen/heartbeat_github by tiger lee · 3 years, 8 months ago
  74. 9bca88d fix: unlock all queues when consumer shutdown in orderly model by dengzhiwen1 · 3 years, 8 months ago
  75. ae93d2a Merge pull request #1000 from Slideee/20230213/rmq by tiger lee · 3 years, 8 months ago
  76. caca3c0 [ISSUE #999] add timeoutMillis param by yechun · 3 years, 8 months ago
  77. c133cca [ISSUE #999] use structs as result sets for admin method by yechun · 3 years, 8 months ago
  78. 62d4513 [ISSUE #999] fix npe by yechun · 3 years, 8 months ago
  79. 26142da fix: client version mismatch (#1009) by qshuai · 3 years, 8 months ago
  80. df5be5b fix: add log when send heartbeat failed by dengzhiwen1 · 3 years, 8 months ago
  81. c8d06a6 [ISSUE #996] invoke user callback and return error info when async process send resp error (#997) by wangfan · 3 years, 8 months ago
  82. daacb8e [ISSUE #999]support admin topicList and groupList method by yechun · 3 years, 8 months ago
  83. a2cf953 fix:logic error when reset retry message's origin topic (#971) by Humkum · 3 years, 9 months ago
  84. 757e639 Merge pull request #987 from humkum/reduce-log-level by cserwen · 3 years, 9 months ago
  85. cfb845b reduce the log level when fetch offset success and remove unnecessary mq by Hankunming · 3 years, 9 months ago
  86. 896a8a3 [ISSUE #975]when close consumer, return directly by wenxuwan · 3 years, 10 months ago
  87. 12740f0 change uuid to google/uuid by 邬奇辉 · 3 years, 10 months ago
  88. f56a2db fix: data race when update subversion for consumer (#962) by cserwen · 3 years, 11 months ago
  89. cad2f66 add api GetOffsetDiffMap (#965) by Kay Du · 3 years, 11 months ago
  90. 0742aac push consumer enable getting offset diff map (#964) by Kay Du · 3 years, 11 months ago
  91. 6bbfc3f [ISSUE #956]fix reset offset remove pq (#957) by 0daypwn · 4 years ago
  92. 96f00c4 [ISSUE #953] fix limiter with goroutine cover (#952) by maqingxiang · 4 years ago
  93. 8afd69f [ISSUE #927] fix processQueue remove offset (#928) by 0daypwn · 4 years ago
  94. c197b50 [ISSUE #931] fix filter message (#932) by 0daypwn · 4 years ago
  95. 5779439 [ISSUE #942] Fix response ResQueryNotFound typo (#948) by Jack Wong · 4 years ago
  96. 620cf96 [ISSUE #942] fix some spell mistakes (#949) by weavernet · 4 years ago
  97. ff80272 [ISSUE #942] correct name typo (#943) by 0daypwn · 4 years ago
  98. 50596e6 Create .asf.yaml by yukon · 4 years ago
  99. 43186ad [#888] incr instanceCount in once and fmt codes (#888) by Xuexue · 4 years ago
  100. b3ede3a [ISSUE #935]fix consumer option validate (#936) by 0daypwn · 4 years ago