This is an automated email from the ASF dual-hosted git repository.
RongtongJin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new 47d0a47c Add lite consumer sub all liteTopic (#1274)
47d0a47c is described below
commit 47d0a47cb9ef300e166f27fec9bd892f47efd63c
Author: Drizzle <[email protected]>
AuthorDate: Fri Jun 12 15:00:17 2026 +0800
Add lite consumer sub all liteTopic (#1274)
Co-authored-by: drizzle.zk <[email protected]>
---
nodejs/package.json | 2 +-
nodejs/src/consumer/LiteSubscriptionManager.ts | 2 ++
2 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/nodejs/package.json b/nodejs/package.json
index e40467e6..49917098 100644
--- a/nodejs/package.json
+++ b/nodejs/package.json
@@ -1,6 +1,6 @@
{
"name": "rocketmq-client-nodejs",
- "version": "1.0.5",
+ "version": "1.0.6",
"description": "RocketMQ Node.js Client",
"main": "dist/index.js",
"types": "dist/index.d.ts",
diff --git a/nodejs/src/consumer/LiteSubscriptionManager.ts
b/nodejs/src/consumer/LiteSubscriptionManager.ts
index 52e153f7..2d89a13b 100644
--- a/nodejs/src/consumer/LiteSubscriptionManager.ts
+++ b/nodejs/src/consumer/LiteSubscriptionManager.ts
@@ -62,6 +62,8 @@ export class LiteSubscriptionManager {
* Start periodic sync of lite subscriptions.
*/
public startUp() {
+ // syncAll after startup for subscribeLite("*")
+ this.syncAllLiteSubscription();
this.syncTimer = setInterval(
() => this.syncAllLiteSubscription(),
SYNC_LITE_SUBSCRIPTION_INTERVAL,
