Sign in
apache
/
rocketmq-clients
/
HEAD
9fe1449
[ISSUE #1309] [Java] Improve gRPC transport resilience (#1310)
by qianye
· 3 days ago
master
5447111
feature(golang): support LiteSimpleConsumer (#1314)
by Quan
· 3 days ago
5939e37
[Go] Fix resource leaks on client close (#1305)
by guyinyou
· 9 days ago
3180b68
fix: add CODECOV_ACTION_KEY token and upgrade actions in golang coverage workflow (#1302)
by lizhimins
· 3 weeks ago
47c2a64
[C++] Fix thread safety bugs and add comprehensive unit tests (#1301)
by lizhimins
· 3 weeks ago
41b65fa
[C++] Update public API and simplify client lifecycle state machine (#1300)
by lizhimins
· 3 weeks ago
9c9ce3c
[C++] Add CMake install/uninstall support and enable tests in CI (#1297)
by lizhimins
· 3 weeks ago
42a965c
feat(consumer): implement LitePushConsumer with FIFO and standard consume services (#1294)
by Drizzle
· 4 weeks ago
315f98e
[Java] Record consumegroup when consumeMessage (#1290)
by ymwneu
· 4 weeks ago
d4de689
[Go] Fix LitePushConsumer.WrapReceiveMessageRequest using wrong AutoRenew value (#1291)
by Quan
· 4 weeks ago
f038a53
[Go] Support offset option for lite topic subscriptions (#1285)
by Yim
· 5 weeks ago
3d8e99f
[Java] Support client properties for observability and management (#1237)
by JYZ
· 6 weeks ago
eb6fe0b
[Java] Build rocketmq-proto from submodule instead of depending on Maven Central (#1287)
by lizhimins
· 6 weeks ago
37cbdf6
Prepare C# SDK 5.2.1 release (#1283)
by rongtong
· 6 weeks ago
csharp-5.2.1
5ef95b8
Prepare Go SDK 5.1.4 release (#1282)
by rongtong
· 6 weeks ago
golang/v5.1.4
471044f
[maven-release-plugin] prepare release java-5.2.1 (#1278)
by lizhimins
· 7 weeks ago
java-5.2.1
7448aa1
[Go] Fix data race in receiveMessage for push and simple consumers (#1275)
by guyinyou
· 7 weeks ago
882c5be
[Golang] fix(process_queue.go): correct log format verbs in receiveMessage error logging (#1253)
by ZM
· 7 weeks ago
47d0a47
Add lite consumer sub all liteTopic (#1274)
by Drizzle
· 7 weeks ago
f17e6df
[Go] Fix Commit/RollBack always returning nil in transaction (#1271)
by guyinyou
· 7 weeks ago
9713aaf
[Go] Fix double execution of telemetry command during recovery (#1270)
by guyinyou
· 7 weeks ago
ec29fca
[Go] Fix inverted hook status in Ack/DLQ methods (#1269)
by guyinyou
· 7 weeks ago
c46bc3f
[C#] Fix SetBody validation logic to correctly reject null and empty body (#1268)
by guyinyou
· 7 weeks ago
061dd50
[C#] Fix missing return after InvalidReceiptHandle in AckMessage and ChangeInvisibleDuration (#1267)
by guyinyou
· 7 weeks ago
e9521d5
fix(golang): add missing return in SendAsync when producer is off (#1264)
by guyinyou
· 7 weeks ago
bf4462c
[Go] Fix missing return after retry scheduling in process_queue (#1265)
by guyinyou
· 7 weeks ago
323fe20
[Go] Fix forwardToDeadLetterQueueLater incorrectly calling ackMessage instead of forwardToDeadLetterQueue (#1266)
by guyinyou
· 7 weeks ago
913d5de
fix(ci): join git diff output to single line for GITHUB_OUTPUT (#1263)
by lizhimins
· 8 weeks ago
189d2d5
fix(ci): fix paths-filter shallow clone failure and cpp coverage token (#1262)
by lizhimins
· 8 weeks ago
446f3be
[C#] Add .NET 10 support and fix build warnings (#1260)
by zynetYu
· 8 weeks ago
039ee85
[C++] Upgrade Bazel 5.2.0 to 6.6.0, add Bazel CI, migrate coverage to CMake (#1261)
by lizhimins
· 8 weeks ago
77fdb6f
Bump protobufjs from 7.5.6 to 7.6.1 in /nodejs (#1254)
by dependabot[bot]
· 8 weeks ago
df8759f
[C++] Fix critical correctness, thread safety, and memory management bugs (#1259)
by lizhimins
· 8 weeks ago
f1df051
[C++] Improve CMake build system, fix warnings, and restore cross-platform CI (#1257)
by lizhimins
· 8 weeks ago
d35c2c2
fix(csharp): correct inverted condition in GetMacAddress to prevent ArgumentOutOfRangeException on macOS arm64 (#1255)
by guyinyou
· 9 weeks ago
e9f2ae7
feat(LitePushConsumer): support concurrent consumption for LitePushConsumer (#1248)
by Quan
· 2 months ago
66b340d
[C++] Support priority message (#1241)
by zhaohai
· 2 months ago
730a172
optimize the nodejs client (#1247)
by Drizzle
· 3 months ago
ca77ac9
fix(ClientImpl.java): broadcast SyncLiteSubscriptionRequest to all route endpoints (#1245)
by Quan
· 3 months ago
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
· 3 months ago
9d026ed
fix(client.go): nil pointer exception during close (#1243)
by Quan
· 3 months ago
6361fe3
refactor(log.go): unify log configuration default value management (#1239)
by Quan
· 3 months ago
a5b541c
fix(log.go): adjust log file size unit and enable local time (#1238)
by Quan
· 3 months ago
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 months ago
73c415b
fix(client.go): handle sync settings error during startup (#1235)
by Quan
· 3 months ago
9cde194
Go client supports Producer with recalling timed/delay messages and Priority Message. (#1231)
by zhaohai
· 3 months ago
d71c6c5
Fix priority issue.Supports lightweight messaging. (#1215)
by zhaohai
· 3 months ago
e05d5a9
[Golang] fix(client.go): fix bug where NotifyClientTermination was never called (#1221)
by Quan
· 4 months ago
3cc5cdf
fix(log.go): improve log directory retrieval logic (#1220)
by Quan
· 4 months ago
d581a03
[Golang] fix(conn): add max receive message size configuration option (#1219)
by Quan
· 4 months ago
1f09375
feat(csharp): parallel FIFO consume by message group (#1218)
by guyinyou
· 4 months ago
17ab1b4
feat(csharp): graceful PushConsumer shutdown aligned with Go client (#1217)
by guyinyou
· 4 months ago
505e1fd
feat(LitePushConsumer): enable Lite Push Consumer to suspend consumption (#1206)
by Quan
· 4 months ago
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
· 4 months ago
e97a2cd
[ISSUE #1196] [Java] Increase max cached message count limit for PushConsumer (#1214)
by lizhimins
· 4 months ago
a96e590
refactor(lite_push_consumer): enable Lite Push Consumer to suspend consumption (#1203)
by Quan
· 4 months ago
5b54c56
nodeJs demo (#975)
by zhaohai
· 5 months ago
5ec167b
Node js push consumer (#1201)
by zhaohai
· 5 months ago
80a5bbf
[ISSUE #1187] [Java] Implementation of lite simple consumer (#1188)
by Quan
· 5 months ago
a5b9584
chore(.licenserc.yaml): add golang/*_mock.go to ignore list (#1193)
by Quan
· 6 months ago
8d5d765
Release python sdk 5.1.1 (#1192)
by zhouli11
· 6 months ago
2a9fb85
[maven-release-plugin] prepare for next development iteration (#1186)
by lizhimins
· 6 months ago
f13d28e
[maven-release-plugin] prepare release java-5.2.0 (#1184)
by lizhimins
· 6 months ago
652a140
[Java] Fix opentelemetry-instrumentation-compatibility CI (#1185)
by qianye
· 6 months ago
c159a67
[ISSUE #1150] [Java] Support OffsetOption for subscribeLite (#1151)
by Quan
· 7 months ago
3c6f6fa
[ISSUE #1161] [Golang] Client support ipv6 hostip:port (#1162)
by SHI
· 7 months ago
1139cfb
[ISSUE #1174] [C++] Optimize the logic for generating the uniqueId of messages (#1175)
by lizhimins
· 7 months ago
601aee5
refactor(lite_push_consumer): use `sync.Map` to replace regular map and fix related method calls (#1171)
by Quan
· 7 months ago
399a39e
[ISSUE #1107] [Golang] LiteTopic support for "RIP‐83 Lite Topic" (#1110)
by cvictory
· 7 months ago
5472484
[Python] Fix PushConsumer not receiving messages (#1169)
by Marandi269
· 7 months ago
ab66ab6
Add example of sending lite_topic in python sdk. (#1170)
by zhouli11
· 7 months ago
0b838e7
Release Python SDK 5.1.0 (#1167)
by zhouli11
· 7 months ago
8903b2f
[ISSUE #1152] [RIP-80] [Java] Implementation of Priority Message (#1153)
by imzs
· 7 months ago
692dd72
[ISSUE #1163] Correct document spelling errors (#1164)
by yx9o
· 7 months ago
d396227
[ISSUE #1159] [C++] Use Pass-by-Value instead of Pass-by-Reference for attemptId in PushConsumer (#1160)
by lizhimins
· 7 months ago
cpp-5.0.4
e7097ae
[ISSUE #1156] [C++] SimpleConsumer support subscription expression (#1158)
by lizhimins
· 7 months ago
a9bb6ff
[ISSUE #1035] [C++] Supports configuring the number of client threads (#1155)
by lizhimins
· 7 months ago
576e61b
golang: Added rate limiting for SimpleConsumer's Receive requests by clientID dimension (#1141)
by guyinyou
· 8 months ago
fd58dab
[ISSUE #1145] Make ClientServiceProvider.loadService Thread-Safe with Lazy Initialization (#1146)
by qianye
· 8 months ago
c47025c
Release python SDK 5.0.9 (#1144)
by zhouli11
· 8 months ago
6a51929
Release Python SDK, version: 5.0.8 (#1142)
by zhouli11
· 8 months ago
ac19e79
[ISSUE #1133] The java client adds the maxStartupAttempts parameter to configure the retry times at startup (#1134)
by qianye
· 8 months ago
90d9f15
Optimize ProducerTransactionMessageExample.java demo
by qianye
· 9 months ago
80962ad
Support fifo parallel consume in go pushconsumer (#1122)
by guyinyou
· 9 months ago
a11dbf8
fix resource (#1119)
by zhaohai
· 9 months ago
2406234
[maven-release-plugin] prepare for next development iteration (#1115)
by lizhimins
· 10 months ago
c996ee9
[maven-release-plugin] prepare release rocketmq-client-java-parent-5.1.0 (#1114)
by lizhimins
· 10 months ago
java-5.1.0
ef21697
[ISSUE #1107] [Java] LiteTopic support for "RIP‐83 Lite Topic" (#1108)
by Quan
· 10 months ago
6cc3717
[ISSUE #1098] [Golang] Ensure proper closure of done channel on receive message error (#1099)
by Lei Zhiyuan
· 11 months ago
306b197
[ISSUE #1075] [Golang] Support ReconnectEndpointsCommand (#1076)
by takagi
· 11 months ago
golang/v5.1.3
3c37fbe
[ISSUE #1070] [Golang] Add SSL configuration when starting the client (#1072)
by takagi
· 11 months ago
0c837c6
[ISSUE #1055] [Golang] Enhance grpc failover resilience (#1069)
by takagi
· 11 months ago
e976290
[ISSUE #1083] [Golang] Triggering the judgment whether it is empty during task execution (#1084)
by takagi
· 11 months ago
7389a30
[ISSUE #1057] [Java] Enhance MessageImpl to allow subclasses to access properties (#1058)
by bcaw-ofeer
· 11 months ago
6bbd251
[ISSUE #1060] [Java] Enhance the logic of MessageInterceptor (#1061)
by bcaw-ofeer
· 11 months ago
ea99f9e
[ISSUE #1081] [Java] Fix missing protos (#1091)
by lizhimins
· 11 months ago
8905f83
[ISSUE #1081] [Java] Support message filtering in interceptors with proper acknowledgment handling (#1082)
by bcaw-ofeer
· 11 months ago
444c764
[Rust] Fix Github Rust Workflow (#1090)
by EnableAsync
· 11 months ago
eec7790
[Rust] Fix Github Rust Workflow (#1089)
by EnableAsync
· 11 months ago
3dc40e9
[ISSUE #1051] Upgrade slf4j version to match current logback version (#1052)
by ymwneu
· 12 months ago
Next »