feat: read enableChangesStream when sync changes stream (#250)

cnpm · Jun 24, 2022 · 0948a71 · 0948a71
1 parent 1cf5c66
commit 0948a71
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/app/core/service/ChangesStreamService.ts b/app/core/service/ChangesStreamService.ts
@@ -62,7 +62,8 @@ export class ChangesStreamService extends AbstractService {
         this.logger.warn('[ChangesStreamService.executeTask:firstSeq] GET %s status: %s, data: %j, since: %s',
           changesStreamRegistry, status, data, since);
       }
-      while (since) {
+      // allow disable changesStream dynamic
+      while (since && this.config.cnpmcore.enableChangesStream) {
         const { lastSince, taskCount } = await this.handleChanges(since, task);
         this.logger.warn('[ChangesStreamService.executeTask:changes] since: %s => %s, %d new tasks, taskId: %s, updatedAt: %j',
           since, lastSince, taskCount, task.taskId, task.updatedAt);